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

[ZEPPELIN-502] Catch exception in logger.error

Browse source
This commit is contained in:
Hervé RIVIERE 2016-04-30 19:59:29 +02:00
parent 1a86ad73ee
commit 7142aa5dde
1 changed files with 8 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
python/src/main/java/org/apache/zeppelin/python/PythonInterpreter.java
View file

@ -84,7 +84,7 @@ public class PythonInterpreter extends Interpreter {
try {
process = builder.start();
} catch (IOException e) {
logger.info(e.getMessage());
logger.error("Can't start python process", e);
}
pythonPid = getPidOfProcess(process);
@ -98,7 +98,7 @@ public class PythonInterpreter extends Interpreter {
try {
bootStrapInterpreter();
} catch (IOException e) {
e.printStackTrace();
logger.error("Can't execute bootstrap.py to initiate python process", e);
}
}
@ -113,7 +113,7 @@ public class PythonInterpreter extends Interpreter {
stdin.close();
stdout.close();
} catch (IOException e) {
logger.info(e.getMessage());
logger.error("Can't close the interpreter", e);
}
}
@ -127,7 +127,7 @@ public class PythonInterpreter extends Interpreter {
writer.write("print (\"*!?flush reader!?*\")\n\n");
writer.flush();
} catch (IOException e) {
e.printStackTrace();
logger.error("Error when sending commands to python process stdin", e);
}
String output = "";
@ -145,7 +145,7 @@ public class PythonInterpreter extends Interpreter {
}
} catch (IOException e) {
e.printStackTrace();
logger.error("Error when sending commands to python process stdout", e);
}
return new InterpreterResult(Code.SUCCESS, output.replaceAll(">>>", "")
.replaceAll("\\.\\.\\.", "").trim());
@ -155,14 +155,14 @@ public class PythonInterpreter extends Interpreter {
public void cancel(InterpreterContext context) {
if (pythonPid > -1) {
try {
logger.info("Sending SIGINT signal to PID" + pythonPid);
logger.info("Sending SIGINT signal to PID : " + pythonPid);
Runtime.getRuntime().exec("kill -SIGINT " + pythonPid);
} catch (IOException e) {
e.printStackTrace();
}
}
else {
logger.info("Non UNIX/Linux system, close the interpreter");
logger.warn("Non UNIX/Linux system, close the interpreter");
close();
}
}
@ -228,6 +228,7 @@ public class PythonInterpreter extends Interpreter {
}
}
catch (Exception e) {
logger.warn("Can't find python pid process", e);
pid = -1;
}
return pid;