Here is my https://github.com/lvhuyen/flink implementation <https://github.com/lvhuyen/flink> of the change. 3 files were updated: StreamExecutionEnvironment.java, StreamExecutionEnvironment.scala, and ContinuousFileMonitoringFunction.java.
All the thanks to Fabian. -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
