flink batch sql使用union all的并行度与-p参数不一致问题

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

flink batch sql使用union all的并行度与-p参数不一致问题

酷酷的浑蛋
在使用flink batch sql的  union all时,任务并行度跟设置的-p参数不一致


例如  select   a from t1 union all select a from t2……….
如果我-p设置了2,那么我union all了几个表,并行度就在-p基础上乘以几,-p=2  union  all了3个表,那么并行度就为变为6了,请问这块怎么限制并行度为’2’?