在Flink上调整水印

Question

我认为水印可以通过两种方式来调整：

将DataSourceStream连接到

• ，通过数据源
• 上的SourceContext.emitWatermark()发送WatermarksStrategy

我是否已经在数据源中释放水印，如果我在数据源操作符之后连接一个新的水印策略，第一个水印是否会被后期水印策略所取代？

本质上，我所处的情况是，我无法控制源事件/数据源，但我需要稍后调整水印。

Answer 1

您可以在Flink管道的任何一点添加一个WatermarkStrategy。下游水印生成器将吃掉任何传入的水印--它所释放的唯一水印将是它生成的水印。此外，源没有必要生成水印(虽然它更好)。