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 9d9b092 commit 5eb7222Copy full SHA for 5eb7222
sql/core/src/main/scala/org/apache/spark/sql/execution/Exchange.scala
@@ -158,7 +158,7 @@ case class Exchange(
158
val rdd = if (needToCopyObjectsBeforeShuffle(part, serializer)) {
159
child.execute().mapPartitions { iter =>
160
val hashExpressions = newMutableProjection(expressions, child.output)()
161
- iter.map(r => (hashExpressions(r).copy, r.copy()))
+ iter.map(r => (hashExpressions(r).copy(), r.copy()))
162
}
163
} else {
164
0 commit comments