Skip to content

Commit aaa51bf

Browse files
committed
Actually avoid calling open() :)
1 parent c7caa5c commit aaa51bf

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/java/org/apache/spark/shuffle/sort/BypassMergeSortShuffleWriter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,7 @@ public void insertAll(Iterator<Product2<K, V>> records) throws IOException {
116116
// result in slower out-of-the-box performance due to these constant-factor overheads. This
117117
// optimization speeds up local microbenchmarking and SQL unit tests.
118118
partitionWriters[i] =
119-
blockManager.getDiskWriter(blockId, file, serInstance, fileBufferSize, writeMetrics).open();
119+
blockManager.getDiskWriter(blockId, file, serInstance, fileBufferSize, writeMetrics);
120120
}
121121
// Creating the file to write to and creating a disk writer both involve interacting with
122122
// the disk, and can take a long time in aggregate when we open many files, so should be

0 commit comments

Comments
 (0)