Skip to content

Commit 0cb1a44

Browse files
committed
Fix merge conflicts
1 parent 37a72bc commit 0cb1a44

File tree

1 file changed

+1
-7
lines changed

1 file changed

+1
-7
lines changed

core/src/main/java/org/apache/spark/shuffle/sort/io/LocalDiskShuffleMapOutputWriter.java

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -97,8 +97,7 @@ public ShufflePartitionWriter getPartitionWriter(int reducePartitionId) throws I
9797
}
9898

9999
@Override
100-
<<<<<<< HEAD
101-
public void commitAllPartitions() throws IOException {
100+
public long[] commitAllPartitions() throws IOException {
102101
// Check the position after transferTo loop to see if it is in the right position and raise a
103102
// exception if it is incorrect. The position will not be increased to the expected length
104103
// after calling transferTo in kernel version 2.6.32. This issue is described at
@@ -112,11 +111,6 @@ public void commitAllPartitions() throws IOException {
112111
"to unexpected behavior when using transferTo. You can set " +
113112
"spark.file.transferTo=false to disable this NIO feature.");
114113
}
115-
||||||| merged common ancestors
116-
public void commitAllPartitions() throws IOException {
117-
=======
118-
public long[] commitAllPartitions() throws IOException {
119-
>>>>>>> origin/master
120114
cleanUp();
121115
File resolvedTmp = outputTempFile != null && outputTempFile.isFile() ? outputTempFile : null;
122116
blockResolver.writeIndexFileAndCommit(shuffleId, mapId, partitionLengths, resolvedTmp);

0 commit comments

Comments
 (0)