fixup! [FLINK-19557] Trigger LeaderRetrievalListener notification upo…

…n ZooKeeper reconnection in ZooKeeperLeaderRetrievalService
apache · Oct 22, 2020 · cd48869 · cd48869
1 parent a606f61
commit cd48869
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...c/main/java/org/apache/flink/runtime/leaderretrieval/ZooKeeperLeaderRetrievalService.java b/...c/main/java/org/apache/flink/runtime/leaderretrieval/ZooKeeperLeaderRetrievalService.java
@@ -18,6 +18,7 @@
 
 package org.apache.flink.runtime.leaderretrieval;
 
+import org.apache.flink.util.ExceptionUtils;
 import org.apache.flink.util.FlinkException;
 import org.apache.flink.util.Preconditions;
 
@@ -174,6 +175,7 @@ private void retrieveLeaderInformationFromZooKeeper() {
 					notifyIfNewLeaderAddress(leaderAddress, leaderSessionID);
 				} catch (Exception e) {
 					leaderListener.handleError(new Exception("Could not handle node changed event.", e));
+					ExceptionUtils.checkInterrupted(e);
 				}
 			} else {
 				LOG.debug("Ignoring node change notification since the service has already been stopped.");