Re: Events triggering JobListener notification

2021-06-09 Thread Arvid Heise
Hi Barak, I think the answer to your question is lies in the javadoc: /** * Callback on job execution finished, successfully or unsuccessfully. It is only called back * when you call {@code execute()} instead of {@code executeAsync()} methods of execution * environments. * * Exactly one of

Events triggering JobListener notification

2021-06-03 Thread Barak Ben Nathan
Hi all, I am using Flink 1.12.1 I’m building a system that creates/cancels Flink Jobs and monitors them. We thought to use org.apache.flink.core.execution.JobListener as a ‘push’ mechanism for job-status-change events. We based this idea on the documentation that stated that JobListener ‘…is