开发者社区> 问答> 正文

使用flinkcdc 假如中间算子的并行度是多个,那么同一主键的消息会进入到同一个并行度吗?

还是说需要自己keyby,大家并行度是不是基本都是默认1

展开
收起
游客3oewgrzrf6o5c 2022-06-23 10:44:48 379 0
1 条回答
写回答
取消 提交回答
  • source算子使用一个并行度,keyby后 sink时指定多个并行度,比如sink时 多并行需要保证相同主键有序,否则会存在数据覆盖的行为(此答案整理自Flink CDC 社区)

    2022-06-23 10:52:45
    赞同 展开评论 打赏
问答分类:
问答地址:
问答排行榜
最热
最新

相关电子书

更多
Phoenix 全局索引原理与实践 立即下载
事务、全局索引、透明分布式 立即下载
低代码开发师(初级)实战教程 立即下载