flink 1.16 kafka 流和自定义流collect后，watermark 消失

[Peihui He]

Hi，

如题，代码大概如下：

stream1  = env.fromSource(kafkaSource, wartermarkStrategy)
stream2 = env.addSource(ConfigSource())

stream1.collect(stream2).process(ProcessFunction()).print()

这种情况下在collect时没有watermark， 是什么原因呢？