在Flink中,并行度的设置是在JobGraph层面进行的,而不是在Task层面进行的。JobGraph是Flink作业的静态描述,包含了作业的所有信息,包括输入输出、算子、并行度等。而Task是JobGraph在执行时的实例化,每个Task负责处理一部分数据。
在你的截图中,我们可以看到JobManager的Config显示了Parallelism为4,这意味着整个Flink作业的并行度被设置为4。然而,这并不意味着每个Task都会以4个并行度运行。在每个Task中,并行度是由算子的并行度决定的。
对于Flink CDC的MySQL连接器来说,它的并行度默认为1,也就是说,无论作业的并行度如何设置,Flink CDC的MySQL连接器只会启动一个并行任务来读取MySQL的binlog。这是因为Flink CDC的MySQL连接器需要保证数据的一致性,不能同时从同一个binlog position读取数据。
如果你想提高Flink CDC的MySQL连接器的并行度,你需要修改连接器的配置,将parallelism属性设置为大于1的值。例如,你可以通过编程的方式,在创建SourceFunction时设置parallelism属性,或者通过命令行的方式,在启动Flink任务时设置parallelism属性。