diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/worker/job/UnassignedShuffleJob.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/worker/job/UnassignedShuffleJob.java index 033ec21d9e8eb3c..9306f3e98becf02 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/worker/job/UnassignedShuffleJob.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/worker/job/UnassignedShuffleJob.java @@ -50,15 +50,16 @@ public List computeAssignedJobs( int expectInstanceNum = degreeOfParallelism(); List biggestParallelChildFragment = getInstancesOfBiggestParallelChildFragment(inputJobs); - int realInstanceNum = - (expectInstanceNum > 0 && expectInstanceNum < biggestParallelChildFragment.size()) + int realInstanceNum + = (expectInstanceNum > 0 && expectInstanceNum < biggestParallelChildFragment.size()) ? expectInstanceNum : biggestParallelChildFragment.size(); // When group by cardinality is smaller than number of backend, only some backends always // process while other has no data to process. // So we shuffle instances to make different backends handle different queries. - List shuffleWorkersInBiggestParallelChildFragment = distinctShuffleWorkers(biggestParallelChildFragment); + List shuffleWorkersInBiggestParallelChildFragment + = distinctShuffleWorkers(biggestParallelChildFragment); Function workerSelector = instanceIndex -> { int selectIndex = instanceIndex % shuffleWorkersInBiggestParallelChildFragment.size(); return shuffleWorkersInBiggestParallelChildFragment.get(selectIndex);