Skip to content

Commit 9887ef1

Browse files
x00228947x00228947
authored andcommitted
remove invalid code
1 parent 135ade9 commit 9887ef1

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
@@ -108,7 +108,7 @@ public void insertAll(Iterator<Product2<K, V>> records) throws IOException {
108108
final File file = tempShuffleBlockIdPlusFile._2();
109109
final BlockId blockId = tempShuffleBlockIdPlusFile._1();
110110
partitionWriters[i] =
111-
blockManager.getDiskWriter(blockId, file, serInstance, fileBufferSize, writeMetrics).open();
111+
blockManager.getDiskWriter(blockId, file, serInstance, fileBufferSize, writeMetrics);
112112
}
113113
// Creating the file to write to and creating a disk writer both involve interacting with
114114
// the disk, and can take a long time in aggregate when we open many files, so should be

0 commit comments

Comments
 (0)