zeppelin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From m...@apache.org
Subject incubator-zeppelin git commit: remote scheduler hangs...
Date Wed, 19 Aug 2015 15:20:44 GMT
Repository: incubator-zeppelin
Updated Branches:
  refs/heads/master cb9f6f770 -> bd5be5092


remote scheduler hangs...

RemoteScheduler#run will end up in an infinite loop if this flag is not set to true while
returning from this if condition

Author: Rajat Gupta <rgupta@qubole.com>

Closes #218 from guptarajat/remote-scheduler-hang and squashes the following commits:

a5d386f [Rajat Gupta] RemoteScheduler#run will end up in an infinite loop if this is not set
and program returns from this path.


Project: http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/commit/bd5be509
Tree: http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/tree/bd5be509
Diff: http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/diff/bd5be509

Branch: refs/heads/master
Commit: bd5be5092a29a0582de28b39e42469f880d241bf
Parents: cb9f6f7
Author: Rajat Gupta <rgupta@qubole.com>
Authored: Sun Aug 16 03:26:27 2015 +0200
Committer: Lee moon soo <moon@apache.org>
Committed: Wed Aug 19 08:20:38 2015 -0700

----------------------------------------------------------------------
 .../main/java/org/apache/zeppelin/scheduler/RemoteScheduler.java    | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-zeppelin/blob/bd5be509/zeppelin-interpreter/src/main/java/org/apache/zeppelin/scheduler/RemoteScheduler.java
----------------------------------------------------------------------
diff --git a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/scheduler/RemoteScheduler.java
b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/scheduler/RemoteScheduler.java
index 904dc22..ec5fcd4 100644
--- a/zeppelin-interpreter/src/main/java/org/apache/zeppelin/scheduler/RemoteScheduler.java
+++ b/zeppelin-interpreter/src/main/java/org/apache/zeppelin/scheduler/RemoteScheduler.java
@@ -289,6 +289,7 @@ public class RemoteScheduler implements Scheduler {
           running.remove(job);
           queue.notify();
         }
+        jobSubmittedRemotely = true;
 
         return;
       }


Mime
View raw message