commit 19998ce97a1907b783fc486c8f624df6f17e39b3
author starocean999 <40539150+starocean999@users.noreply.github.com> Mon Nov 06 22:55:03 2023 +0800
committer GitHub <noreply@github.com> Mon Nov 06 08:55:03 2023 -0600
tree d9425e984a0e87e140095863470fd0658b7bdbc1
parent 9ccfd1870143b92420bde0d1a36ba89f2180ce5a

[fix](nereids)only enable colocate scan for one phase global parttion topn in some condition #26473 (#26481)

fe/fe-core/src/main/java/org/apache/doris/nereids/glue/translator/PhysicalPlanTranslator.java

diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/glue/translator/PhysicalPlanTranslator.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/glue/translator/PhysicalPlanTranslator.java
index 3da1e99..58e0cd8 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/nereids/glue/translator/PhysicalPlanTranslator.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/glue/translator/PhysicalPlanTranslator.java
@@ -1523,8 +1523,8 @@
         addPlanRoot(inputFragment, partitionSortNode, partitionTopN);
         // in pipeline engine, we use parallel scan by default, but it broke the rule of data distribution
         // we need turn of parallel scan to ensure to get correct result.
-        // TODO: nereids forbid all parallel scan under PhysicalSetOperation temporary
-        if (findOlapScanNodesByPassExchangeAndJoinNode(inputFragment.getPlanRoot())) {
+        if (inputFragment.getDataPartition().getType() != TPartitionType.RANDOM
+                && findOlapScanNodesByPassExchangeAndJoinNode(inputFragment.getPlanRoot())) {
             inputFragment.setHasColocatePlanNode(true);
         }
         return inputFragment;