Github user cloud-fan commented on a diff in the pull request:
https://github.com/apache/spark/pull/21529#discussion_r194511635
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/EnsureRequirements.scala
---
@@ -227,9 +228,16 @@ case class EnsureRequirements(conf: SQLConf) extends
Rule[SparkPlan] {
currentOrderOfKeys: Seq[Expression]): (Seq[Expression],
Seq[Expression]) = {
val leftKeysBuffer = ArrayBuffer[Expression]()
val rightKeysBuffer = ArrayBuffer[Expression]()
+ val alreadyUsedIndexes = mutable.Set[Int]()
--- End diff --
nit: maybe `pickedIndexes`?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
