File tree Expand file tree Collapse file tree 1 file changed +1
-1
lines changed
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer Expand file tree Collapse file tree 1 file changed +1
-1
lines changed Original file line number Diff line number Diff line change @@ -647,7 +647,7 @@ object LimitPushDown extends Rule[LogicalPlan] {
647647 // There is a Project between LocalLimit and Join if they do not have the same output.
648648 case LocalLimit (exp, project @ Project (_, join : Join )) =>
649649 LocalLimit (exp, project.copy(child = pushLocalLimitThroughJoin(exp, join)))
650- // Push down limit 1 and turn Aggregate into Project through Aggregate if it is group only.
650+ // Push down limit 1 through Aggregate and turn Aggregate into Project if it is group only.
651651 case Limit (le @ IntegerLiteral (1 ), a : Aggregate ) if a.groupOnly =>
652652 Limit (le, Project (a.output, LocalLimit (le, a.child)))
653653 case Limit (le @ IntegerLiteral (1 ), p @ Project (_, a : Aggregate )) if a.groupOnly =>
You can’t perform that action at this time.
0 commit comments