see inline Il ven 13 nov 2020, 14:31 Matthias Pohl <matth...@ververica.com> ha scritto:
> 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? > it's actually very simple...the main class creates a batch execution env using ExecutionEnvironment.getExecutionEnvironment(), I register a job listener to the env and I do some stuff before calling env.execute(). The listener is executed correctly but if I use the RestClusterClient to sibmit the jobGraph exyracted from that main contained in a jar, the program is executed as usual but the job listener is not called. - What cluster backend and application do you use to execute the job? > I use a standalone session cluster for the moment - Is there anything suspicious you can find in the logs that might be > related? > no unfortunately.. > 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 >>> >>
