开发者社区 问答 正文

一个source多个sink的同步问题

是1个小时才到来。10:00- 11:00的数据,11:01分到来。

但是现在的问题是这个数据来了,我的第一个sink马上就保存到数据库了, 11:02进数据库。但是第二个sink,因为有tumble window,所以10:00- 11:00的数据,需要到12:01,才会触发这个窗口。

*来自志愿者整理的flink邮件归档

展开
收起
小阿矿 2021-12-07 15:34:24 2083 分享
分享
版权
举报
1 条回答
写回答
取消 提交回答
  • 窗口的触发逻辑就是这样的,必须watermark达到了窗口结束时间才会触发,可能10-11点的窗口中的数据最大只有10:59呢*来自志愿者整理的flink邮件归档

    2021-12-07 16:42:50 举报
    赞同 评论

    评论

    全部评论 (0)

    登录后可评论
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等