You can try JobListener which you can register to ExecutionEnvironment. https://github.com/apache/flink/blob/master/flink-core/src/main/java/org/apache/flink/core/execution/JobListener.java
Mark Davis <moda...@protonmail.com> 于2020年6月6日周六 上午12:00写道： > Hi there, > > I am running a Batch job with several outputs. > Is there a way to run some code(e.g. release a distributed lock) after all > outputs are finished? > > Currently I do this in a try-finally block around > ExecutionEnvironment.execute() call, but I have to switch to the detached > execution mode - in this mode the finally block is never run. > > Thank you! > > Mark > -- Best Regards Jeff Zhang
