Hi Puneet,
Are you submitting the Flink jobs using the "/bin/flink" command line tool
to a cluster in session mode?
Maybe the command line tool is just "fire and forget" submitting the job to
the cluster, that's why the listeners are firing immediately.
Can you try to use "env.executeAsync()" inst
Hi,
I have registered a job listener which notifies slack with JobId on successful
submission. Also it notifies slack on successful/failed Execution. Now this job
listener is working as expected when running on local IDE , but somehow
behaving unexpectedly when running on a cluster i.e. both o
