Flink Zookeeper leader change v 1.9.X

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

Flow of events when Flink Iterations are used in DataStream API

Hi All, We have a sample flow like below : Operator A Operator B Operator C Operator D Operator E We have implemented iterations where the result of code done in Operator C is checked in Operator D and conditionally pushed back into Operator B. Now according to this stackoverflow answer (