Flink Job Cleanup Sequence

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

Flink Job Cleanup Sequence

Abdul Qadeer
Hi!

Is there a FLIP or doc describing how Flink (1.8+) cleans up the states of a Job upon cancellation in Zookeeper HA mode? I am trying to find the sequence of cleaning between SubmittedJobGraphs in Zookeeper, blobs in FS maintained by BlobStore etc.