You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2016/04/26 13:55:04 UTC
[2/2] flink git commit: [FLINK-3809] Add missing breaks in
ZKRetrievalService
[FLINK-3809] Add missing breaks in ZKRetrievalService
This closes #1935.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4a69f72a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4a69f72a
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/4a69f72a
Branch: refs/heads/master
Commit: 4a69f72a3fa3cfc17cdc473a0c45099416a0ecb8
Parents: 55a88a4
Author: zentol <ch...@apache.org>
Authored: Tue Apr 26 13:21:03 2016 +0200
Committer: Till Rohrmann <tr...@apache.org>
Committed: Tue Apr 26 13:54:23 2016 +0200
----------------------------------------------------------------------
.../runtime/leaderretrieval/ZooKeeperLeaderRetrievalService.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/4a69f72a/flink-runtime/src/main/java/org/apache/flink/runtime/leaderretrieval/ZooKeeperLeaderRetrievalService.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/leaderretrieval/ZooKeeperLeaderRetrievalService.java b/flink-runtime/src/main/java/org/apache/flink/runtime/leaderretrieval/ZooKeeperLeaderRetrievalService.java
index 6c2dbef..e2501a3 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/leaderretrieval/ZooKeeperLeaderRetrievalService.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/leaderretrieval/ZooKeeperLeaderRetrievalService.java
@@ -148,14 +148,18 @@ public class ZooKeeperLeaderRetrievalService implements LeaderRetrievalService,
switch (newState) {
case CONNECTED:
LOG.debug("Connected to ZooKeeper quorum. Leader retrieval can start.");
+ break;
case SUSPENDED:
LOG.warn("Connection to ZooKeeper suspended. Can no longer retrieve the leader from " +
"ZooKeeper.");
+ break;
case RECONNECTED:
LOG.info("Connection to ZooKeeper was reconnected. Leader retrieval can be restarted.");
+ break;
case LOST:
LOG.warn("Connection to ZooKeeper lost. Can no longer retrieve the leader from " +
"ZooKeeper.");
+ break;
}
}
}