XComp commented on code in PR #23773:
URL: https://github.com/apache/flink/pull/23773#discussion_r1403041122
##########
flink-runtime/src/main/java/org/apache/flink/runtime/leaderretrieval/ZooKeeperLeaderRetrievalDriver.java:
##########
@@ -69,8 +68,40 @@ public class ZooKeeperLeaderRetrievalDriver implements
LeaderRetrievalDriver {
private final FatalErrorHandler fatalErrorHandler;
+ /**
+ * Each {@code ZooKeeperLeaderRetrievalDriver} has its own watcher
initialized. There is a bug
Review Comment:
hm, ok ... thanks for clarification. But that brings me to the point where I
would be in favor of not fixing it on Flink's side at all. That needs to be
addressed in ZooKeeper (as @tisonkun pointed out with his reference to
[ZOOKEEPER-4625](https://issues.apache.org/jira/browse/ZOOKEEPER-4625)). I'm
curious to hear what your take on this is?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
