flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "忝忝向仧" <153488...@qq.com>
Subject 回复: 1585972779129_EWCE6K_[]R%C3V)5C{NJE)K
Date Sat, 04 Apr 2020 09:44:47 GMT
还没有么?
我这里邮件是附上附件了的

那我图片该怎么发送?


------------------&nbsp;原始邮件&nbsp;------------------
发件人:&nbsp;"libenchao"<libenchao@gmail.com&gt;;
发送时间:&nbsp;2020年4月4日(星期六) 下午5:42
收件人:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

主题:&nbsp;Re: 1585972779129_EWCE6K_[]R%C3V)5C{NJE)K



Hi,这里还是没有看到你的附件呢~

忝忝向仧 <153488125@qq.com&gt; 于2020年4月4日周六 下午5:32写道:

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

-- 

Benchao Li
School of Electronics Engineering and Computer Science, Peking University
Tel:+86-15650713730
Email: libenchao@gmail.com; libenchao@pku.edu.cn
Mime
  • Unnamed multipart/related (inline, 8-Bit, 0 bytes)
View raw message