Hi to all, In my program I'd like to infer from a mysql table the list of directory I have to output on hdfs (status=0). Once my job finish to clean each directory and update the status value of my sql table. How can I do that in Flink? Is there any callback on the dataset.output() finish?
Best, Flavio
