We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent bcc43d1 commit efd58edCopy full SHA for efd58ed
1 file changed
sql/core/src/main/scala/org/apache/spark/sql/execution/exchange/ShuffleExchange.scala
@@ -259,7 +259,6 @@ object ShuffleExchange {
259
//
260
// Note that we don't perform local sort if the new partitioning has only 1 partition, under
261
// that case all output rows go to the same partition.
262
-
263
val newRdd = if (isRoundRobin && SparkEnv.get.conf.get(SQLConf.SORT_BEFORE_REPARTITION)) {
264
rdd.mapPartitionsInternal { iter =>
265
val recordComparatorSupplier = new Supplier[RecordComparator] {
0 commit comments