removed unnecessary code.

apache · Mar 7, 2017 · 1395875 · 1395875
1 parent 276011e
commit 1395875
Showing 1 changed file with 0 additions and 22 deletions.
diff --git a/python/src/main/java/org/apache/zeppelin/python/PythonInterpreter.java b/python/src/main/java/org/apache/zeppelin/python/PythonInterpreter.java
@@ -30,7 +30,6 @@
 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 @@ private void createGatewayServerAndStartScript() {
 
     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 InterpreterResult interpret(String cmd, InterpreterContext contextInterpr
     }
   }
 
-  /**
-   * 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);