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
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