你试了 FileProcessingMode.PROCESS_CONTINUOUSLY 了么? On Mon, 16 Nov 2020 at 09:23, hepingtao <hectorhe...@aliyun.com.invalid> wrote:
> 我也遇到类似的需求,需要增量读取日志文件内容,最终发现用一个已废弃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/