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

Posted by 猫猫 on Dec 18, 2019; 1:27am
URL: http://apache-flink.370.s1.nabble.com/flink-sql-confluent-schema-avro-topic-tp1264p1265.html

env.addSource(flinkKafkaConsumer).assignTimestampsAndWatermarks(...)
env.addSource(flinkKafkaConsumer).flatMap(...).assignTimestampsAndWatermarks(...);

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