执行sql查询,出现部分节点内部pipeline 在LOCAL_EXCHANGE_SINK_OPERATOR 的下一步只把数据分配给了部分PipelineXTask

Viewed 26

doris版本为 2.1.7,3节点 8c32g

我造了96m行数据,写了个sql进行行转列操作将数据变为1m行数据,打开profile查看数据执行情况发现,在Pipeline 1这一步时,只有一个doris节点是由4个PipelineXTask来处理数据的,也就是每个Task处理8m数据。但是另外两个节点只有两个Task在处理数据,各处理了16m数据,另外两个Task就闲着
image.png

用同样的数据,同样的sql出现过一次完全均分的情况,后面立刻又执行了一次,结果还是不均分。请问可能是什么愿意导致的呢。
image.png

1 Answers

可以发一下完整的profile吗