Re: Jobgraph not getting deleted from Zookeeper

2020-05-19 Thread Fritz Budiyanto
Forgot to mentioned, Flink version is 1.9.2 On May 19, 2020 at 6:22 PM, Fritz Budiyanto wrote: Hi All, I have been seeing this issue several time where JobGraph are not cleaned up properly. As a result, when Flink cluster is restarted, it will attempt to do HA restore on a checkpoint which

Jobgraph not getting deleted from Zookeeper

2020-05-19 Thread Fritz Budiyanto
Hi All, I have been seeing this issue several time where JobGraph are not cleaned up properly. As a result, when Flink cluster is restarted, it will attempt to do HA restore on a checkpoint which doesn't exist anymore and the new restarted cluster eventually go give up and stay down. The wor