海里看土
海里看土_个人页
海里看土
文章
0
问答
1
视频
0
个人介绍
暂无个人介绍
擅长的技术
暂无更多信息
暂无更多信息
-
回答了问题
2019-07-17
Flink Sliding Window Join 不输出数据？
看你设置了watermark，用的应该是事件时间。触发窗口的条件watermark的时间大于窗口结束的时间。在使用kafka作为DataSource的，stream中的watermark是分区中最小的watermark2.用的是流join，watermark会选取两条流中最小的watermark作为双流的watermark。3.只有当双流的watermark大于窗口结束的时间才会触发窗口。赞0 踩0 评论0
滑动查看更多
暂无更多信息