From b3e619c82ffc9ccb0bb9e2d4eb25f3e6995eebfc Mon Sep 17 00:00:00 2001 From: 924060929 <924060929@qq.com> Date: Wed, 9 Oct 2024 20:57:57 +0800 Subject: [PATCH] share hash table --- .../plans/distribute/worker/job/AbstractUnassignedScanJob.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/distribute/worker/job/AbstractUnassignedScanJob.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/distribute/worker/job/AbstractUnassignedScanJob.java index 95052aeda68211b..1caa65d0ccd1334 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/distribute/worker/job/AbstractUnassignedScanJob.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/distribute/worker/job/AbstractUnassignedScanJob.java @@ -92,7 +92,7 @@ protected List insideMachineParallelization( int instanceNum = degreeOfParallelism(scanSourceMaxParallel); List instanceToScanRanges; - if (useLocalShuffleToAddParallel) { + if (useLocalShuffleToAddParallel && instanceNum > 1) { // only generate one instance to scan all data, in this step instanceToScanRanges = scanSource.parallelize( scanNodes, 1