开发者社区> 问答> 正文

join输出的时候,为什么触发窗口的数据第二条就触发了?

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

展开
收起
玛丽莲梦嘉 2021-12-03 18:38:51 1383 0
1 条回答
写回答
取消 提交回答
  • https://ci.apache.org/projects/flink/flink-docs-release-1.10/zh/dev/event_timestamps_watermarks.html

    Both timestamps and watermarks are specified as milliseconds since the Java epoch of 1970-01-01T00:00:00Z.

    看一下这个, 从0 timestamp开始切分*来自志愿者整理的FLINK邮件归档

    2021-12-03 19:01:15
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载