[SPARK-25299] Don't set map status twice in bypass merge sort shuffle writer (#541)

mccheah · mccheah · commit f982df7cc1e1 · 2019-06-26T15:43:42.000-07:00
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
@@ -186,10 +186,6 @@ public void write(Iterator<Product2<K, V>> records) throws IOException {
       }
       throw e;
     }
-    mapStatus = MapStatus$.MODULE$.apply(
-        blockManager.shuffleServerId(),
-        DefaultMapShuffleLocations.get(blockManager.shuffleServerId()),
-        partitionLengths);
   }
 
   @VisibleForTesting

Original file line number	Diff line number	Diff line change
`@@ -186,10 +186,6 @@ public void write(Iterator<Product2<K, V>> records) throws IOException {`
`186`	`186`	`}`
`187`	`187`	`throw e;`
`188`	`188`	`}`
`189`		`- mapStatus = MapStatus$.MODULE$.apply(`
`190`		`- blockManager.shuffleServerId(),`
`191`		`- DefaultMapShuffleLocations.get(blockManager.shuffleServerId()),`
`192`		`- partitionLengths);`
`193`	`189`	`}`
`194`	`190`
`195`	`191`	`@VisibleForTesting`