各位大佬:

    场景描述:  利用flink监控某个目录下的文件,如果文件内数据增加(追加)了,就进行处理。

    使用方法:  我现在利用ContinuousFileMonitoringFunction 
作为source,采用PROCESS_CONTINUOUSLY的处理模式。

    遇见的问题:   当使用这种方法时每次追加文件内容后都是全量的读取文件数据,有没有什么方法让我追加文件后只读取到追加的内容?

回复