[FLINK-2604] [runtime] Adds synchronization to stop method of ZooKeeperLeaderElectionService

31aedede · Till Rohrmann · 6a58aade · 31aedede
隐藏空白更改
内联并排

Showing with 4 addition and 2 deletion

flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderElectionService.java ...untime/leaderelection/ZooKeeperLeaderElectionService.java +4 -2

未找到文件。
--- 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
@@ -114,8 +114,10 @@ public class ZooKeeperLeaderElectionService implements LeaderElectionService, Le
 		leaderLatch.close();
 		client.close();

-		confirmedLeaderSessionID = null;
-		issuedLeaderSessionID = null;
+		synchronized (lock) {
+			confirmedLeaderSessionID = null;
+			issuedLeaderSessionID = null;
+		}
 	}

 	@Override