开发者社区> 问答> 正文

Flink在写入Iceberg表时,如何确保主键相同的数据写入到同一个bucket?

Flink在写入Iceberg表时,如何确保主键相同的数据写入到同一个bucket?

展开
收起
萝卜丝丸子 2024-08-07 19:10:47 25 0
1 条回答
写回答
取消 提交回答
  • 由于Flink表的DDL不直接支持Iceberg的bucket定义,我们通过在Flink DDL的property中定义bucket来确保主键相同的数据写入到同一个bucket。这种方式允许我们在Flink任务中灵活地配置数据分区策略。image.png

    2024-08-07 19:55:44
    赞同 3 展开评论 打赏
问答排行榜
最热
最新

相关电子书

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