Re: 关于直接设置Watermark和flatmap后再设置的疑问

Tue, 17 Dec 2019 22:10:47 -0800 

flatmap 逻辑中，你是否对消息记录的时间处理了吗，watermark 的更新的逻辑是比前一次 watermark 的时间截要大同时非空。

猫猫 <[email protected]> 于2019年12月18日周三 上午9:27写道：

> env.addSource(flinkKafkaConsumer).assignTimestampsAndWatermarks(...)
>
> env.addSource(flinkKafkaConsumer).flatMap(...).assignTimestampsAndWatermarks(...);
>
> 使用kafka进行消费，直接设置Watermark和经过flatMap()以后再设置，会产生什么样的区别和影响。
> flatMap可能会将数据处理为1-N条。那么在这种情况下，还能够保证kafka的精确一次吗？

回复