-原始邮件--
> 发件人:"libenchao" 发送时间:2020年4月4日(星期六) 晚上11:04
> 收件人:"user-zh"
> 主题:Re: 回复： 回复： Flink双流Join问题
>
>
>
> 两个stream输入的场景，operator的watermark是取两者的最小值。
> 所以虽然这条数据在第一个流里面看起来已经是肯定迟到了，但是有可能看第二个流的watermark它还没有过期。
>
>
> 忝忝向仧 <15
jerry1
> 2 tom3=jerry2
> 2 tom3=jerry3
> 2 tom_late=jerry1
> 2 tom_late=jerry2
> 2 tom_late=jerry3
>
>
>
>
>
>
>
>
>
>
>
>
> --原始邮件--
> 发件人:"Djeng Lee" 发送时间:2020年4月4日(星期六) 晚上6:35
> 收件人:"user-zh
刚刚我说的不严谨
Start = 100055000 - (100055000 - 0 + 3000) % 3000 = 100053000
End = 100053000 + 3000
//源码位置，所以窗口开端并不是你传入首条记录的作为开端。窗口划分是从0时间戳切过来的。
文档说明:
https://ci.apache.org/projects/flink/flink-docs-release-1.10/zh/dev/event_timestamps_watermarks.html
相关代码
public static long
