Hello,
Thank you for your replay. I will use MapPartition for anomaly detection
for batch job. But i saw that flink has planned to unify stream and batch
according to the folowing link
https://flink.apache.org/news/2019/02/13/unified-batch-streaming-blink.html
, so in this case how can i use MapPar
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 impleme
