From e54198f479f8366288c432ae77de54b3683416c7 Mon Sep 17 00:00:00 2001 From: zentol Date: Mon, 16 Nov 2015 11:35:28 +0100 Subject: [PATCH] [FLINK-2914] Add missing break Statement in ZKJobGraphStore --- .../runtime/jobmanager/ZooKeeperSubmittedJobGraphStore.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 a9ac77a603723..b0a2eba978e79 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 void childEvent(CuratorFramework client, PathChildrenCacheEvent event) 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 void childEvent(CuratorFramework client, PathChildrenCacheEvent event) 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;