flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trohrm...@apache.org
Subject [1/2] flink git commit: [FLINK-3810] Add missing breaks in ZKElectionService
Date Tue, 26 Apr 2016 11:55:03 GMT
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 <chesnay@apache.org>
Authored: Tue Apr 26 13:20:46 2016 +0200
Committer: Till Rohrmann <trohrmann@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;
 		}
 	}
 }


Mime
View raw message