Elgato_dark/zeppelin
1
0
Fork 0
mirror of https://github.com/apache/zeppelin synced 2026-05-24 09:38:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Fix typo, log exit value of a succesful shell commnad

Browse source
This commit is contained in:
karuppayya 2016-01-13 10:17:31 +05:30
parent 351888d108
commit d259c48e44
2 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
shell/src/main/java/org/apache/zeppelin/shell/ShellInterpreter.java
View file

@ -79,7 +79,9 @@ public class ShellInterpreter extends Interpreter {
Map<String, Object> info = runningJob.info();
info.put(EXECUTOR_KEY, executor);
try {
executor.execute(cmdLine);
int exitVal = executor.execute(cmdLine);
logger.info("Paragraph " + contextInterpreter.getParagraphId()
+ "return with exit value: " + exitVal);
return new InterpreterResult(InterpreterResult.Code.SUCCESS, outputStream.toString());
} catch (ExecuteException e) {
int exitValue = e.getExitValue();

2
zeppelin-interpreter/src/main/java/org/apache/zeppelin/interpreter/remote/RemoteInterpreterProcess.java
View file

@ -256,7 +256,7 @@ public class RemoteInterpreterProcess implements ExecuteResultHandler {
public void setMaxPoolSize(int size) {
if (clientPool != null) {
//Size + 2 for progress poller , cancel opeartion
//Size + 2 for progress poller , cancel operation
clientPool.setMaxTotal(size + 2);
}
}