From 9cd1d3a371c786b993c2ec8f9815d18d70f3b4fa Mon Sep 17 00:00:00 2001 From: 924060929 <924060929@qq.com> Date: Thu, 6 Jun 2024 16:41:31 +0800 Subject: [PATCH] fix --- .../apache/doris/nereids/worker/job/UnassignedShuffleJob.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 120c7adf17d33bb..38688f2e1b120f2 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 @@ -71,8 +71,8 @@ protected int degreeOfParallelism() { return 1; } - // TODO: when we use nested loop join do right outer / semi / anti join, we should add an exchange node with - // gather distribute under the nested loop join + // TODO: check we use nested loop join do right outer / semi / anti join, + // we should add an exchange node with gather distribute under the nested loop join int expectInstanceNum = -1; if (ConnectContext.get() != null && ConnectContext.get().getSessionVariable() != null) {