我也遇到类似的需求，需要增量读取日志文件内容，最终发现用一个已废弃Deprecated的方法 readFileStream 是可以实现的，代码如下：
val stream = env.readFileStream(inputPath, 10, FileMonitoringFunction.WatchType.PROCESS_ONLY_APPENDED) 源码里说明可以用 readFile(FileInputFormat, String, FileProcessingMode, long) 方法替代，但事实上FileProcessingMode并没有对应的 watchType与PROCESS_ONLY_APPENDED的功能是一致的，readFileStream这个Source Function在未来彻底删除后，如果又没有提供内置的替代方案，就只能自己想办法实现了。 所以我的问题是，既然之前有增量读取的方法，为什么要突然废弃掉又不提供替代方案呢？这类需求不合理吗？这让我很不理解，希望得到大家的解答，谢谢！ -- Sent from: http://apache-flink.147419.n8.nabble.com/
