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 onJobSubmitted and onJobExecuted are being called simultaneously on submitting a real time data streaming job. Currently, jobs are being deployed in session mode.
Thanks, Puneet Duggal
