可以中途产生，走这个接口 org.apache.flink.streaming.api.datastream.DataStream#assignTimestampsAndWatermarks(org.apache.flink.api.common.eventtime.WatermarkStrategy<T>)
麻烦贴一下你加 watermark 的代码和 pipeline 看一下啥情况 Best, tison. Xavier <[email protected]> 于2021年3月7日周日 下午7:51写道： > 想问下社区，watermark必须加在数据源上吗？顺便想问下一般用什么方式来调watermark，我自己本地有发现加在map > function之后，watermark会自动重置为默认值的情况。 > 谢谢！ > -- > > Best Regards, > *Xavier* >
