开发者社区> 问答> 正文

在 Flink 1.15 中,如何实现跨源节点的 Watermark 对齐?

在 Flink 1.15 中,如何实现跨源节点的 Watermark 对齐?

展开
收起
不吃核桃 2024-08-07 18:15:36 10 0
1 条回答
写回答
取消 提交回答
  • 在 Flink 1.15 中,通过新的 Source 接口实现的数据源节点可以启用 Watermark 对齐功能。用户可以定义对齐组,如果某个源节点的 Watermark 与其他节点相比领先过多,可以暂停从该节点中消费数据,以实现 Watermark 的对齐。这一功能有助于解决因数据源速率不同而在下游节点中产生的问题。

    2024-08-07 18:40:05
    赞同 3 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载