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 09:44:47 UTC
回复: 1585972779129_EWCE6K_[]R%C3V)5C{NJE)K
还没有么?
我这里邮件是附上附件了的
那我图片该怎么发送?
------------------ 原始邮件 ------------------
发件人: "libenchao"<libenchao@gmail.com>;
发送时间: 2020年4月4日(星期六) 下午5:42
收件人: "user-zh"<user-zh@flink.apache.org>;
主题: Re: 1585972779129_EWCE6K_[]R%C3V)5C{NJE)K
Hi,这里还是没有看到你的附件呢~
忝忝向仧 <153488125@qq.com> 于2020年4月4日周六 下午5:32写道:
> 各位好:
> 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
Re: 回复: 1585972779129_EWCE6K_[]R%C3V)5C{NJE)K
Posted by Djeng Lee <le...@gmail.com>.
���ɿ�����
������: ������ <15...@qq.com>
��: "user-zh@flink.apache.org" <us...@flink.apache.org>
����: 2020��4��4�� ������ ����5:45
�ռ���: libenchao <us...@flink.apache.org>
����: �ظ��� 1585972779129_EWCE6K_[]R%C3V)5C{NJE)K
��û��ô?
�������ʼ��Ǹ��ϸ����˵�
[cid:C747E283@6D082D3C.0F57885E.jpg]
����ͼƬ����ô����?
------------------ ԭʼ�ʼ� ------------------
������: "libenchao"<li...@gmail.com>;
����ʱ��: 2020��4��4��(������) ����5:42
�ռ���: "user-zh"<us...@flink.apache.org>;
����: Re: 1585972779129_EWCE6K_[]R%C3V)5C{NJE)K
Hi�����ﻹ��û�п�����ĸ�����~
������ <15...@qq.com> ��2020��4��4������ ����5:32���
> ���:
> 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