casel.chen Mon, 14 Jun 2021 19:19:12 -0700
flink sql cdc发到kafka,显示下游写kafka并行度只有1,有没有办法提高并行度呢?
显示job-parallelism, table.exec.resource.default-parallelism, parallelism.default 都是 24,但execution graph显示parallelism还是1,我设置了pipeline.operator-chaining=false