flink-commits mailing list archives

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


Mime
View raw message