Skip to content

Commit c167a0d

Browse files
committed
remove eliminate local limit
1 parent 314cb1e commit c167a0d

File tree

1 file changed

+0
-2
lines changed
  • sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer

1 file changed

+0
-2
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1464,8 +1464,6 @@ object EliminateLimits extends Rule[LogicalPlan] {
14641464
def apply(plan: LogicalPlan): LogicalPlan = plan transformDown {
14651465
case Limit(l, child) if canEliminate(l, child.maxRows) =>
14661466
child
1467-
case LocalLimit(l, child) if canEliminate(l, child.maxRows) =>
1468-
child
14691467

14701468
case GlobalLimit(le, GlobalLimit(ne, grandChild)) =>
14711469
GlobalLimit(Least(Seq(ne, le)), grandChild)

0 commit comments

Comments
 (0)