Hi, My flink job needs to do something when the pipeline execution has ended. The job code is like this:
createSomeStream().applySomeOperators(); env.execute(jobName); doSomeCleanupTasks(); It looks like doSomeCleanupTasks() can be called while the pipeline is still running. The job is for processing a bounded stream, so it doesn't run forever. Is it possible to achieve this so doSomeCleanupTasks is called only when the pipeline has processed all the data? This happens when the runtime mode is STREAMING. Would running it in BATCH mode make any difference? Regards, Luke
