Details
-
Bug
-
Status: Closed
-
Blocker
-
Resolution: Fixed
-
1.15.0
-
None
Description
The new multi component leader election driver behaves different when the service is closed.
The ZooKeeperLeaderElectionDriver#close method closes the Zookeeper connection. In contrast, the MultipleComponentLeaderElectionDriverAdapter#close (also a LeaderElectionDriver object) only unregisters the event handler. It relies on the ZooKeeperMultipleComponentLeaderElectionDriver#close method to close the Zookeeper connection. Currently this method is only called when the HighAvailabilityServices are stopped. This difference in behavior means that previously enabled tests are not working anymore FLINK-25235.
Together with dmvk, I propose that we align the behavior of the MultipleComponentLeaderElectionDriverAdapter to the existing behavior. We can do so by closing the Zookeeper connection once all components that are part of the multiple component leader election have stopped.
PS: I use ZooKeeper here as an example, the same can be said about Kubernetes as well.
Attachments
Issue Links
- relates to
-
FLINK-26630 EmbeddedHaServices is not made for recovery on a single instance
- Open
- Testing discovered
-
FLINK-25235 Re-enable ZooKeeperLeaderElectionITCase#testJobExecutionOnClusterWithLeaderChange
- Resolved
- links to