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 t
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
