Skip to content

Commit 0ce6b14

Browse files
ueshinkai-chi
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 <ueshin@databricks.com> Signed-off-by: Wenchen Fan <wenchen@databricks.com> (cherry picked from commit dad2d82) Signed-off-by: Wenchen Fan <wenchen@databricks.com>
1 parent b674a1b commit 0ce6b14

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

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
@@ -269,7 +269,7 @@ object ShuffleExchangeExec {
269269
}
270270
// The comparator for comparing row hashcode, which should always be Integer.
271271
val prefixComparator = PrefixComparators.LONG
272-
val canUseRadixSort = SparkEnv.get.conf.get(SQLConf.RADIX_SORT_ENABLED)
272+
val canUseRadixSort = SQLConf.get.enableRadixSort
273273
// The prefix computer generates row hashcode as the prefix, so we may decrease the
274274
// probability that the prefixes are equal when input rows choose column values from a
275275
// limited range.

0 commit comments

Comments
 (0)