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

Thu, 06 Jul 2023 22:02:48 -0700 

您好：
     我在尝试使用coGroup对两条流进行连接，使用的依赖版本是flink-streaming-java:1.16.1，流连接的代码如下：
     DataStream<T3> dataStream3= 
dataStream1.coGroup(dataStream2).where(Data1::getKey).equalTo(Data2::getKey)
        .window(TumblingEventTimeWindows.of(Time.seconds(5*60)))//窗口大小5min
        .allowedLateness(Time.seconds(0))//设置窗口等待时长
       .with(coGroupFunction)
     coGroupFunction extends RichCoGroupFunction来实现
有两个问题想咨询下：
    1. 如何在窗口函数中获取水位线  ，我是使用的RichCoGroupFunction，没有找到对应的接口方法获取水位线
    2. 
两条流连接的水位线是如何推动的，我以为是以两条流中较低的水位线来决定窗口的关闭，但是按照上述使用方法，其中一条流的水位线到了窗口的关闭时间，窗口就关闭了，看起来是以高的
          为准，是否有设置项控制以低的为准？
     谢谢您的阅读，期待回复！

回复