You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2015/11/17 15:39:19 UTC
[4/6] flink git commit: [FLINK-2914] [runtime] Add missing break
Statement in ZKJobGraphStore
[FLINK-2914] [runtime] Add missing break Statement in ZKJobGraphStore
This closes #1359
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/442fcb19
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/442fcb19
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/442fcb19
Branch: refs/heads/master
Commit: 442fcb196f9bf9fada2278b78c8447e65f0c85e0
Parents: 1f52899
Author: zentol <ch...@apache.org>
Authored: Mon Nov 16 11:35:28 2015 +0100
Committer: Stephan Ewen <se...@apache.org>
Committed: Tue Nov 17 15:38:06 2015 +0100
----------------------------------------------------------------------
.../runtime/jobmanager/ZooKeeperSubmittedJobGraphStore.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/442fcb19/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/ZooKeeperSubmittedJobGraphStore.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/ZooKeeperSubmittedJobGraphStore.java b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/ZooKeeperSubmittedJobGraphStore.java
index a9ac77a..b0a2eba 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/ZooKeeperSubmittedJobGraphStore.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/ZooKeeperSubmittedJobGraphStore.java
@@ -345,7 +345,7 @@ public class ZooKeeperSubmittedJobGraphStore implements SubmittedJobGraphStore {
case CONNECTION_SUSPENDED:
LOG.warn("ZooKeeper connection SUSPENDED. Changes to the submitted job " +
"graphs are not monitored (temporarily).");
-
+ break;
case CONNECTION_LOST:
LOG.warn("ZooKeeper connection LOST. Changes to the submitted job " +
"graphs are not monitored (permanently).");
@@ -354,7 +354,7 @@ public class ZooKeeperSubmittedJobGraphStore implements SubmittedJobGraphStore {
case CONNECTION_RECONNECTED:
LOG.info("ZooKeeper connection RECONNECTED. Changes to the submitted job " +
"graphs are monitored again.");
-
+ break;
case INITIALIZED:
LOG.info("SubmittedJobGraphsPathCacheListener initialized");
break;