给kafka吐数据时每条记录之间休眠1秒试试.
文档位置
https://ci.apache.org/projects/flink/flink-docs-release-1.10/zh/dev/event_timestamps_watermarks.html
https://ci.apache.org/projects/flink/flink-docs-release-1.10/zh/dev/stream/operators/joining.html
AssignerWithPeriodicWatermarks assigns timestamps and generates
Hi,
感觉有点不对，我试着用stream1输入:
1 tom1 1553503185000
1 tom2 1553503186000
1 tom3 1553503187000
1 tom4 1553503188000
1 tom_late 1553503185000
stream2输入:
1 jerry2 1553503186000
1 jerry3 1553503187000
1 jerry4 1553503188000
但是结果打印的是:
currentTimeStamp:
额，明白了，意思是说两个流情况下
比如，stream1里面晚来的那条
1 tom_late 1553503185000的水印是1553503188000
但是stream2里面,这条1,jerry1,1553503185000的水印是1553503185000
所以取最小的，因此还是会被打印?
是这么理解么?
--原始邮件--
Hi:
还有个疑问,我特意构造了个乱序的消息,还是3秒一个窗口
stream1:
1 tom1 1553503185000
1 tom2 1553503186000
1 tom3 1553503187000
1 tom4 1553503188000
1 tom_late 1553503185000
stream2:
1 jerry1 1553503185000
1 jerry2 1553503186000
1 jerry3 1553503187000
1 jerry4 1553503188000
我代码还是之前的代码，定义水印都是maxDelayAllowed =
文档说明:
https://ci.apache.org/projects/flink/flink-docs-release-1.10/zh/dev/event_timestamps_watermarks.html
这个网页我打不开，有其他的地址么?
谢谢
--原始邮件--
发件人:"Djeng Lee"https://ci.apache.org/projects/flink/flink-docs-release-1.10/zh/dev/event_timestamps_watermarks.html
相关代码
