flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "猫猫" <16770...@qq.com>
Subject 关于直接设置Watermark和flatmap后再设置的疑问
Date Wed, 18 Dec 2019 01:27:07 GMT
env.addSource(flinkKafkaConsumer).assignTimestampsAndWatermarks(...)
env.addSource(flinkKafkaConsumer).flatMap(...).assignTimestampsAndWatermarks(...);

使用kafka进行消费,直接设置Watermark和经过flatMap()以后再设置,会产生什么样的区别和影响。
flatMap可能会将数据处理为1-N条。那么在这种情况下,还能够保证kafka的精确一次吗?
Mime
  • Unnamed multipart/alternative (inline, 8-Bit, 0 bytes)
View raw message