开发者社区> 问答> 正文

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

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

相关电子书

更多
Get rid of traditional ETL, Move to Spark! 立即下载
BUILDING REALTIME DATA PIPELINES WITH KAFKA CONNECT AND SPARK STREAMING 立即下载
Real-time Platform for Second Look Use Case using Spark and Kafka 立即下载