Update Optimizer.scala

markhamstra · Apr 29, 2015 · 485c61c · 485c61c
1 parent f03fe7f
commit 485c61c
Showing 1 changed file with 3 additions and 0 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
@@ -171,6 +171,9 @@ object ColumnPruning extends Rule[LogicalPlan] {
 
       Project(substitutedProjection, child)
 
+    case Project(projectList, Limit(exp, child)) =>
+      Limit(exp, Project(projectList, child))
+
     // Eliminate no-op Projects
     case Project(projectList, child) if child.output == projectList => child
   }