We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c628daf commit 752b8deCopy full SHA for 752b8de
sql/core/src/main/scala/org/apache/spark/sql/execution/Exchange.scala
@@ -269,7 +269,7 @@ private[sql] case class EnsureRequirements(sqlContext: SQLContext) extends Rule[
269
operator.withNewChildren(newChildren)
270
}
271
272
- def apply(plan: SparkPlan): SparkPlan = plan.transformUp {
+ def apply(plan: SparkPlan): SparkPlan = plan.transformUp {
273
case operator: SparkPlan =>
274
ensureDistributionAndOrdering(ensureChildNumPartitionsAgreementIfNecessary(operator))
275
0 commit comments