remove eliminate local limit

apache · Nov 14, 2020 · c167a0d · c167a0d
1 parent 314cb1e
commit c167a0d
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala
@@ -1464,8 +1464,6 @@ object EliminateLimits extends Rule[LogicalPlan] {
   def apply(plan: LogicalPlan): LogicalPlan = plan transformDown {
     case Limit(l, child) if canEliminate(l, child.maxRows) =>
       child
-    case LocalLimit(l, child) if canEliminate(l, child.maxRows) =>
-      child
 
     case GlobalLimit(le, GlobalLimit(ne, grandChild)) =>
       GlobalLimit(Least(Seq(ne, le)), grandChild)