开发者社区> 问答> 正文

一个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 2060 0
1 条回答
写回答
取消 提交回答
  • 窗口的触发逻辑就是这样的,必须watermark达到了窗口结束时间才会触发,可能10-11点的窗口中的数据最大只有10:59呢*来自志愿者整理的flink邮件归档

    2021-12-07 16:42:50
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
BUILDING REALTIME DATA PIPELINES WITH KAFKA CONNECT AND SPARK STREAMING 立即下载
Get rid of traditional ETL, Move to Spark! 立即下载
Apache Phoenix and HBase: Past, Present and Future of SQL over HBase 立即下载