You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by "casel.chen" <ca...@126.com> on 2021/06/15 02:18:54 UTC

flink sql cdc到kafka，如何提高sink并行度？

flink sql cdc发到kafka，显示下游写kafka并行度只有1，有没有办法提高并行度呢？

显示job-parallelism, table.exec.resource.default-parallelism, parallelism.default 都是 24，但execution graph显示parallelism还是1，我设置了pipeline.operator-chaining=false