File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
core/src/main/java/org/apache/spark/util/collection/unsafe/sort Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -143,9 +143,10 @@ private UnsafeExternalSorter(
143143 this .recordComparator = recordComparator ;
144144 this .prefixComparator = prefixComparator ;
145145 // Use getSizeAsKb (not bytes) to maintain backwards compatibility for units
146- // this.fileBufferSizeBytes = (int) conf.getSizeAsKb("spark.shuffle.file.buffer", "32k") * 1024;
146+ // this.fileBufferSizeBytes = (int) conf.getSizeAsKb("spark.shuffle.file.buffer", "32k") * 1024
147147 this .fileBufferSizeBytes = 32 * 1024 ;
148- // The spill metrics are stored in a new ShuffleWriteMetrics, and then discarded (this fixes SPARK-16827).
148+ // The spill metrics are stored in a new ShuffleWriteMetrics,
149+ // and then discarded (this fixes SPARK-16827).
149150 // TODO: Instead, separate spill metrics should be stored and reported (tracked in SPARK-3577).
150151 this .writeMetrics = new ShuffleWriteMetrics ();
151152
You can’t perform that action at this time.
0 commit comments