Skip to content

Commit c0ec9b3

Browse files
committed
4MB constant -> bufSize
1 parent 2f21853 commit c0ec9b3

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/scala/org/apache/spark/sort/UnsafeSort.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ object UnsafeSort {
4242

4343
val outputFile = s"$baseFolder/part$part.dat"
4444

45-
val os = new BufferedOutputStream(new FileOutputStream(outputFile), 4 * 1024 * 1024)
45+
val os = new BufferedOutputStream(new FileOutputStream(outputFile), bufSize)
4646
val buf = new Array[Byte](100)
4747
var count = 0
4848
val arrOffset = BYTE_ARRAY_BASE_OFFSET

0 commit comments

Comments
 (0)