回复： flink sql 如何提高下游并发度？

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 为需要的并发数。 J

如何确定分配内存的大小

请问在启动flink 任务时，要如何确定该分配多少内存给 jobmanager，分配多少给 taskmanager，当我们指定 -ytm 1024 或 -ytm 2048 的依据是什么？

退订

退订

回复： 退订

退订 在2021年8月31日 23:01，Leonard Xu 写道： Hi, Please send email to dev-unsubscr...@flink.apache.org if you want to unsubscribe the mail from d...@flink.apache.org . Please send email to user-unsubscr...@flink.apache.org