全部面试刷题微服务数据库消息队列搜索引擎大数据运维 go语言人工智能

flinkcdc 如果把参数 sink.parallelism 值设成大于1，这不会导致sink 出来的消息是乱序的吗？

提问者：Rae 问题分类：大数据

flinkcdc 如果把参数 sink.parallelism 值设成大于1，这不会导致sink 出来的消息是乱序的吗？意思是和binlog 里SQL实际执行顺序不一致

Flink FlinkCdc

发布于：2个月前 (02-28) IP属地：

1 个回答

ε小可爱з

如果你代码里没有再分区就不会。增量阶段所有数据都是在一个subtask里，你设置多并行度如果没再分区其他subtask也没数据

发布于：2个月前 (02-28) IP属地：

我来回答