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 8d39fe2fe9c7b..5c10293355316 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 @@ -148,7 +148,7 @@ public void confirmLeaderSessionID(UUID leaderSessionID) { @Override public boolean hasLeadership() { - return leaderLatch.hasLeadership(); + return leaderLatch.hasLeadership(); } @Override