diff --git a/core/src/main/java/org/apache/spark/shuffle/sort/BypassMergeSortShuffleWriter.java b/core/src/main/java/org/apache/spark/shuffle/sort/BypassMergeSortShuffleWriter.java index 434286175e415..c35ab8aeaebe7 100644 --- a/core/src/main/java/org/apache/spark/shuffle/sort/BypassMergeSortShuffleWriter.java +++ b/core/src/main/java/org/apache/spark/shuffle/sort/BypassMergeSortShuffleWriter.java @@ -186,10 +186,6 @@ public void write(Iterator> records) throws IOException { } throw e; } - mapStatus = MapStatus$.MODULE$.apply( - blockManager.shuffleServerId(), - DefaultMapShuffleLocations.get(blockManager.shuffleServerId()), - partitionLengths); } @VisibleForTesting