[SPARK-24497][SQL] minor change

peter-toth · peter-toth · commit d9cc8645ffa8 · 2019-01-16T11:02:02.000+01:00
Change-Id: I7bd2cb3968c1d47df6ce9d0f82afc4351500b187
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/basicPhysicalOperators.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/basicPhysicalOperators.scala
@@ -252,8 +252,7 @@ case class RecursiveTableExec(
       }
 
       val newRecursiveTerm = recursiveTerm.transform {
-        case se @ ShuffleExchangeExec(_, _, co) =>
-          co.map(c => se.copy(coordinator = Some(c.copy))).getOrElse(se)
+        case se @ ShuffleExchangeExec(_, _, Some(co)) => se.copy(coordinator = Some(co.copy))
       }
       if (level > 0) {
         newRecursiveTerm.reset()

Original file line number	Diff line number	Diff line change
`@@ -252,8 +252,7 @@ case class RecursiveTableExec(`
`252`	`252`	`}`
`253`	`253`
`254`	`254`	`val newRecursiveTerm = recursiveTerm.transform {`
`255`		`- case se @ ShuffleExchangeExec(_, _, co) =>`
`256`		`- co.map(c => se.copy(coordinator = Some(c.copy))).getOrElse(se)`
	`255`	`+ case se @ ShuffleExchangeExec(_, _, Some(co)) => se.copy(coordinator = Some(co.copy))`
`257`	`256`	`}`
`258`	`257`	`if (level > 0) {`
`259`	`258`	`newRecursiveTerm.reset()`