Repository: flink Updated Branches: refs/heads/master 172fcfa1e -> 4a69f72a3
[FLINK-3810] Add missing breaks in ZKElectionService Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/55a88a4b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/55a88a4b Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/55a88a4b Branch: refs/heads/master Commit: 55a88a4bffd5f2ebdae48e5d96d4e9663f0cabdc Parents: 172fcfa Author: zentol <ches...@apache.org> Authored: Tue Apr 26 13:20:46 2016 +0200 Committer: Till Rohrmann <trohrm...@apache.org> Committed: Tue Apr 26 13:54:19 2016 +0200 ---------------------------------------------------------------------- .../runtime/leaderelection/ZooKeeperLeaderElectionService.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/55a88a4b/flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderElectionService.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderElectionService.java b/flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderElectionService.java index 3abd71c..d39bf2a 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderElectionService.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderElectionService.java @@ -334,15 +334,19 @@ public class ZooKeeperLeaderElectionService implements LeaderElectionService, Le switch (newState) { case CONNECTED: LOG.debug("Connected to ZooKeeper quorum. Leader election can start."); + break; case SUSPENDED: LOG.warn("Connection to ZooKeeper suspended. The contender " + leaderContender.getAddress() + "no longer participates in the leader election."); + break; case RECONNECTED: LOG.info("Connection to ZooKeeper was reconnected. Leader election can be restarted."); + break; case LOST: // Maybe we have to throw an exception here to terminate the JobManager LOG.warn("Connection to ZooKeeper lost. The contender " + leaderContender.getAddress() + "no longer participates in the leader election."); + break; } } }
