flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [4/6] flink git commit: [FLINK-2914] [runtime] Add missing break Statement in ZKJobGraphStore
Date Tue, 17 Nov 2015 14:39:19 GMT
[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 <chesnay@apache.org>
Authored: Mon Nov 16 11:35:28 2015 +0100
Committer: Stephan Ewen <sewen@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;


Mime
View raw message