combine the limits.

gatorsmile · gatorsmile · commit 77105e391a0a · 2015-12-23T14:45:41.000-08:00
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
@@ -157,8 +157,8 @@ object SetOperationPushDown extends Rule[LogicalPlan] with PredicateHelper {
     case Limit(exp, Union(left, right)) =>
       Limit(exp,
         Union(
-          Limit(exp, left),
-          Limit(exp, right)
+          CombineLimits(Limit(exp, left)),
+          CombineLimits(Limit(exp, right))
         )
       )
 

Original file line number	Diff line number	Diff line change
`@@ -157,8 +157,8 @@ object SetOperationPushDown extends Rule[LogicalPlan] with PredicateHelper {`
`157`	`157`	`case Limit(exp, Union(left, right)) =>`
`158`	`158`	`Limit(exp,`
`159`	`159`	`Union(`
`160`		`- Limit(exp, left),`
`161`		`- Limit(exp, right)`
	`160`	`+ CombineLimits(Limit(exp, left)),`
	`161`	`+ CombineLimits(Limit(exp, right))`
`162`	`162`	`)`
`163`	`163`	`)`
`164`	`164`