Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/20036#discussion_r158776742
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/joins/SortMergeJoinExec.scala
---
@@ -440,8 +440,9 @@ case class SortMergeJoinExec(
val spillThreshold = getSpillThreshold
val inMemoryThreshold = getInMemoryThreshold
+ // inline mutable state since not many join operations in a task
--- End diff --
nit: `Inline`
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]