Skip to content

Commit caad3d7

Browse files
committed
Merge pull request #3 from aarondav/patch-1
4MB constant -> bufSize
2 parents 2f21853 + c0ec9b3 commit caad3d7

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)