flink 1.12 及以上版本 sql kafka sink 支持参数： sink.parallelism 指定 sink
的并行度
On 2022/1/11 17:06, 许友昌 wrote:
hi,
设置了parallelism=10 ,实际上是分配了 10 个 slot，flink 是会共享 slot 的，所以 sink 会有 10 线程。
在2022年1月11日 16:53，RS 写道：
Hi，
请教下，比如设置了parallelism=10，source kafka的topic分区为3，那source、后面的处理和sink的并发度是3还是10？
hi,
设置了parallelism=10 ,实际上是分配了 10 个 slot，flink 是会共享 slot 的，所以 sink 会有 10 线程。
在2022年1月11日 16:53，RS 写道：
Hi，
请教下，比如设置了parallelism=10，source kafka的topic分区为3，那source、后面的处理和sink的并发度是3还是10？
如果source是10的话，那还有7个线程就空闲了？
在 2022-01-11 11:10:41，"Caizhi Weng" 写道：
Hi！
可以设置 parallelism.default 为需要的并发数。
hi
是 10 目前 source 还不支持单独设置并发度,但是 sink 是支持的，当然如果没有单独设置的话 sink 也是 10
Best
JasonLee
在2022年01月11日 16:52，RS 写道：
Hi，
请教下，比如设置了parallelism=10，source kafka的topic分区为3，那source、后面的处理和sink的并发度是3还是10？
如果source是10的话，那还有7个线程就空闲了？
在 2022-01-11 11:10:41，"Caizhi Weng" 写道：
Hi！
可以设置 parallelism.default
