hi source 端的并发保持和 partition 的个数一样就行了,不要大于 partition 个数,因为这会导致 subtask 空跑,浪费资源,你只需要把 map 的并行度调大即可.
----- Best Wishes JasonLee -- Sent from: http://apache-flink.147419.n8.nabble.com/
hi source 端的并发保持和 partition 的个数一样就行了,不要大于 partition 个数,因为这会导致 subtask 空跑,浪费资源,你只需要把 map 的并行度调大即可.
----- Best Wishes JasonLee -- Sent from: http://apache-flink.147419.n8.nabble.com/