Skip to content

Commit dad2d82

Browse files
ueshincloud-fan
authored andcommitted
[SPARK-23207][SQL][FOLLOW-UP] Use SQLConf.get.enableRadixSort instead of SparkEnv.get.conf.get(SQLConf.RADIX_SORT_ENABLED).
## What changes were proposed in this pull request? This is a follow-up of apache#20393. We should read the conf `"spark.sql.sort.enableRadixSort"` from `SQLConf` instead of `SparkConf`, i.e., use `SQLConf.get.enableRadixSort` instead of `SparkEnv.get.conf.get(SQLConf.RADIX_SORT_ENABLED)`, otherwise the config is never read. ## How was this patch tested? Existing tests. Closes apache#23046 from ueshin/issues/SPARK-23207/conf. Authored-by: Takuya UESHIN <[email protected]> Signed-off-by: Wenchen Fan <[email protected]>
1 parent 3649fe5 commit dad2d82

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/ShuffleExchangeExec.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -280,7 +280,7 @@ object ShuffleExchangeExec {
280280
}
281281
// The comparator for comparing row hashcode, which should always be Integer.
282282
val prefixComparator = PrefixComparators.LONG
283-
val canUseRadixSort = SparkEnv.get.conf.get(SQLConf.RADIX_SORT_ENABLED)
283+
val canUseRadixSort = SQLConf.get.enableRadixSort
284284
// The prefix computer generates row hashcode as the prefix, so we may decrease the
285285
// probability that the prefixes are equal when input rows choose column values from a
286286
// limited range.

0 commit comments

Comments
 (0)