You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by 忝忝向仧 <15...@qq.com> on 2020/04/04 08:47:17 UTC

Flink双流Join问题

各位好:&nbsp; &nbsp; &nbsp; &nbsp; Flink双流Join遇到一个问题，能否解释下，谢谢.
&nbsp; &nbsp; &nbsp; &nbsp; ds1和ds2分别读取kafka两个流数据，使用event time和watermark特性，3s的一个翻滚窗口，定义如下:
&nbsp; &nbsp; &nbsp; &nbsp; 最后，join输出的时候，为什么触发窗口的数据第二条就触发了?
&nbsp; &nbsp; &nbsp; &nbsp; 按照水印的触发条件应该是watermark_time&gt;=window_endtime.那么，这里应该是1000000057000这条数据来了后才会触发，但是结果却是56000就触发了.为什么?
&nbsp; &nbsp; &nbsp; &nbsp;&nbsp;





结果:

Re: Flink双流Join问题

Posted by Benchao Li <li...@gmail.com>.

Hi
你的图片在邮件中显示不了。可以先把图片上传到第三方图床再把链接放到这里，或者直接以文本的形式发送。

忝忝向仧 <15...@qq.com> 于2020年4月4日周六 下午4:47写道：

> 各位好:
>         Flink双流Join遇到一个问题，能否解释下，谢谢.
>         ds1和ds2分别读取kafka两个流数据，使用event time和watermark特性，3s的一个翻滚窗口，定义如下:
>         最后，join输出的时候，为什么触发窗口的数据第二条就触发了?
>
> 按照水印的触发条件应该是watermark_time>=window_endtime.那么，这里应该是1000000057000这条数据来了后才会触发，但是结果却是56000就触发了.为什么?
>
>
> 结果:
>
>
>

-- 

Benchao Li
School of Electronics Engineering and Computer Science, Peking University
Tel:+86-15650713730
Email: libenchao@gmail.com; libenchao@pku.edu.cn