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 9306f3e98becf02..120c7adf17d33bb 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
@@ -20,7 +20,6 @@
 import org.apache.doris.nereids.worker.Worker;
 import org.apache.doris.nereids.worker.WorkerManager;
 import org.apache.doris.planner.ExchangeNode;
-import org.apache.doris.planner.NestedLoopJoinNode;
 import org.apache.doris.planner.PlanFragment;
 import org.apache.doris.qe.ConnectContext;
 
@@ -72,12 +71,8 @@ protected int degreeOfParallelism() {
             return 1;
         }
 
-        List<NestedLoopJoinNode> nestedLoopJoins = fragment.getPlanRoot()
-                .collectInCurrentFragment(NestedLoopJoinNode.class::isInstance);
-        // when we use nested loop join do right outer / semi / anti join, the instance must be 1.
-        if (!nestedLoopJoins.isEmpty()) {
-            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
 
         int expectInstanceNum = -1;
         if (ConnectContext.get() != null && ConnectContext.get().getSessionVariable() != null) {