fix condition

astroshim · astroshim · commit 60da1c3cfe15 · 2016-09-28T01:18:47.000+09:00
diff --git a/spark/src/main/java/org/apache/zeppelin/spark/PySparkInterpreter.java b/spark/src/main/java/org/apache/zeppelin/spark/PySparkInterpreter.java
@@ -317,7 +317,7 @@ public InterpreterResult interpret(String st, InterpreterContext context) {
       long startTime = System.currentTimeMillis();
       while (pythonScriptInitialized == false
           && pythonscriptRunning
-          && System.currentTimeMillis() - startTime > MAX_TIMEOUT_SEC * 1000) {
+          && System.currentTimeMillis() - startTime < MAX_TIMEOUT_SEC * 1000) {
         try {
           pythonScriptInitializeNotifier.wait(1000);
         } catch (InterruptedException e) {
