executor: Fix push downed topN won't replace correlated column problem (

#53097) (#53152) close #52777
pingcap · May 10, 2024 · d917e21 · d917e21
1 parent d1e3dee
commit d917e21
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/executor/builder.go b/executor/builder.go
@@ -3128,6 +3128,12 @@ func (b *executorBuilder) corColInDistPlan(plans []plannercore.PhysicalPlan) boo
 					return true
 				}
 			}
+		case *plannercore.PhysicalTopN:
+			for _, byItem := range x.ByItems {
+				if len(expression.ExtractCorColumns(byItem.Expr)) > 0 {
+					return true
+				}
+			}
 		case *plannercore.PhysicalTableScan:
 			for _, cond := range x.LateMaterializationFilterCondition {
 				if len(expression.ExtractCorColumns(cond)) > 0 {