It would run in the client side where ExecutionEnvironment is created. Mark Davis <moda...@protonmail.com> 于2020年6月6日周六 下午8:14写道：
> Hi Jeff, > > Thank you very much! That is exactly what I need. > > Where the listener code will run in the cluster deployment(YARN, k8s)? > Will it be sent over the network? > > Thank you! > > Mark > > ‐‐‐‐‐‐‐ Original Message ‐‐‐‐‐‐‐ > On Friday, June 5, 2020 6:13 PM, Jeff Zhang <zjf...@gmail.com> wrote: > > 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 > > > -- Best Regards Jeff Zhang
