Peihui He Sun, 13 Nov 2022 22:40:48 -0800
Hi, 如题,代码大概如下:
stream1 = env.fromSource(kafkaSource, wartermarkStrategy) stream2 = env.addSource(ConfigSource()) stream1.collect(stream2).process(ProcessFunction()).print() 这种情况下在collect时没有watermark, 是什么原因呢?