我已经建立了我的第一个玩具flink，我想做一件非常简单的事情：连续读取本地文件并打印内容。
问题是，每次我更新本地文件，flink打印所有行时，我希望它只打印新添加的行。
代码段：

final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
String path = "/home/foobar/input";
TextInputFormat inputFormat = new TextInputFormat(new Path(path));
inputFormat.setCharsetName("UTF-8");
DataStreamSource<String> ds = env.readFile(inputFormat, path,
                FileProcessingMode.PROCESS_CONTINUOUSLY, 60000l, BasicTypeInfo.STRING_TYPE_INFO);
ds.print();
env.execute("jobname02");

有人知道我做错了什么吗？谢谢你的帮助。