Hello,

I noticed there's a change [1] coming up in Flink 1.14.0 in the ZooKeeper
tree structure ZooKeeper HA services maintains.

I didn't spot any migration logic from the old (< 1.14.0) structure to the
new. Did I miss something?

If you have a Flink cluster running with 1.13.X and let's say add a
JobManage with 1.14.0 and terminate the original so that the new one
becomes the leader, how's the new one going to understand the data in
ZooKeeper? There are naturally more cases where the same compatibility
issue should be handled, this example should illustrate the issue.

Regards,
Juha

[1] https://issues.apache.org/jira/browse/FLINK-22636

Reply via email to