Hi Flavio, thanks for sharing this with the Flink community. Could you answer the following questions, please: - What's the code of your Job's main method? - What cluster backend and application do you use to execute the job? - Is there anything suspicious you can find in the logs that might be related?
Best, Matthias On Thu, Nov 12, 2020 at 7:48 PM Flavio Pompermaier <pomperma...@okkam.it> wrote: > Actually what I'm experiencing is that the JobListener is executed > successfully if I run my main class from the IDE, while the job listener is > not fired at all if I submit the JobGraph of the application to a cluster > using the RestClusterClient.. > Am I doing something wrong? > > My main class ends with the env.execute() and i do > env.registerJobListener() when I create the Exceution env > via ExecutionEnvironment.getExecutionEnvironment(). > > Thanks in advance for any help, > Flavio > > On Thu, Nov 12, 2020 at 2:13 PM Flavio Pompermaier <pomperma...@okkam.it> > wrote: > >> Hello everybody, >> I'm trying to use the JobListener to track when a job finishes (with >> Flink 1.11.0). >> It works great but I have the problem that logs inside the onJobExecuted >> are not logged anywhere..is it normal? >> >> Best, >> Flavio >> >
