Hello, I created a process for an anomaly detection with a flatMap. I need to know the end of each job at the level of the flatMap to be able to flush a buffer in the output collector.
I saw that it is possible to get status of job by using ExecutionEnvironment, but i don't know how i can implement it. Is it possible to recover the end of each job in the flatMap of any processing source with last iteration of job or to have in advance the size of the partition that each job must deal ? Thank's in advance ! Anissa -- <http://www.dcbrain.com/> <https://twitter.com/dcbrain_feed?lang=fr> <https://www.linkedin.com/company/dcbrain> <https://www.youtube.com/channel/UCSJrWPBLQ58fHPN8lP_SEGw> Pensez à la planète, imprimer ce papier que si nécessaire
