提交 442fcb19 编写于 作者: Z zentol 提交者: Stephan Ewen

[FLINK-2914] [runtime] Add missing break Statement in ZKJobGraphStore

This closes #1359
上级 1f52899a
......@@ -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;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册