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 <[email protected]> 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 <[email protected]> Authored: Sun Aug 16 03:26:27 2015 +0200 Committer: Lee moon soo <[email protected]> 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; }
