Github user WangTaoTheTonic commented on the issue:
https://github.com/apache/flink/pull/3599
@StephanEwen
I've done the changes, which introduce a new smarter leader latch(the
reason why i write a new class is that `handleStateChange` method is private in
`LeaderLatch` and cannot be overrided) which will wait a connection timeout
duration when connection to zookeeper is broken, instead of revoke leadership
immediately.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
