Re: Flink Zookeeper leader change v 1.9.X

2021-03-03 Thread Chesnay Schepler
1) This could occur due to a number of reasons, like processes crashing, network issues between ZK and Flink, or the JobManager being stuck in some blocking operation for a long time. You will need to take a look at the ZK/Flink logs to narrow things down. 2) For FLINK-14091 the issue was not

Flink Zookeeper leader change v 1.9.X

2021-03-02 Thread Varun Chakravarthy Senthilnathan
Hi, We are using flink version 1.9.1 and in a long-running environment, we encountered the specific issue mentioned in : https://issues.apache.org/jira/browse/FLINK-14091 While we are working on upgrading our version, 1. Why does zookeeper go for a leader change? As far as we checked, there