退订

两个流进行coGroup，水位线推进问题

您好： 我在尝试使用coGroup对两条流进行连接，使用的依赖版本是flink-streaming-java:1.16.1，流连接的代码如下： DataStream dataStream3= dataStream1.coGroup(dataStream2).where(Data1::getKey).equalTo(Data2::getKey) .window(TumblingEventTimeWindows.of(Time.seconds(5*60)))//窗口大小5min