mirror of
https://github.com/apache/zeppelin
synced 2026-05-24 09:38:26 +00:00
removed unnecessary code.
This commit is contained in:
parent
276011e32d
commit
1395875b51
1 changed files with 0 additions and 22 deletions
|
|
@ -30,7 +30,6 @@ import java.util.Collection;
|
|||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.Properties;
|
||||
import java.util.regex.Matcher;
|
||||
import java.util.regex.Pattern;
|
||||
|
||||
import org.apache.commons.exec.CommandLine;
|
||||
|
|
@ -147,7 +146,6 @@ public class PythonInterpreter extends Interpreter implements ExecuteResultHandl
|
|||
|
||||
try {
|
||||
Map env = EnvironmentUtils.getProcEnvironment();
|
||||
//env.put("PYTHONPATH", "python/py4j-0.8.2.1-src.zip");
|
||||
env.put("PYTHONPATH", ZEPPELIN_PY4JPATH);
|
||||
executor.execute(cmd, env, this);
|
||||
//executor.execute(cmd);
|
||||
|
|
@ -347,26 +345,6 @@ public class PythonInterpreter extends Interpreter implements ExecuteResultHandl
|
|||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Checks if there is a syntax error or an exception
|
||||
*
|
||||
* @param output Python interpreter output
|
||||
* @return true if syntax error or exception has happened
|
||||
*/
|
||||
private boolean pythonErrorIn(String output) {
|
||||
boolean isError = false;
|
||||
String[] outputMultiline = output.split("\n");
|
||||
Matcher errorMatcher;
|
||||
for (String row : outputMultiline) {
|
||||
errorMatcher = errorInLastLine.matcher(row);
|
||||
if (errorMatcher.find() == true) {
|
||||
isError = true;
|
||||
break;
|
||||
}
|
||||
}
|
||||
return isError;
|
||||
}
|
||||
|
||||
public void interrupt() throws IOException {
|
||||
if (pythonPid > -1) {
|
||||
logger.info("Sending SIGINT signal to PID : " + pythonPid);
|
||||
|
|
|
|||
Loading…
Reference in a new issue