Fix build

mccheah · mccheah · commit c125a1443351 · 2019-08-30T16:02:42.000-07:00
diff --git a/core/src/main/java/org/apache/spark/shuffle/sort/UnsafeShuffleWriter.java b/core/src/main/java/org/apache/spark/shuffle/sort/UnsafeShuffleWriter.java
@@ -470,7 +470,6 @@ private void mergeSpillsWithTransferTo(
           Closeables.close(resolvedChannel, copyThrewExecption);
         }
         long numBytes = writer.getNumBytesWritten();
-        partitionLengths[partition] = numBytes;
         writeMetrics.incBytesWritten(numBytes);
       }
       threwException = false;
@@ -482,7 +481,6 @@ private void mergeSpillsWithTransferTo(
         Closeables.close(spillInputChannels[i], threwException);
       }
     }
-    return partitionLengths;
   }
 
   @Override

Original file line number	Diff line number	Diff line change
`@@ -470,7 +470,6 @@ private void mergeSpillsWithTransferTo(`
`470`	`470`	`Closeables.close(resolvedChannel, copyThrewExecption);`
`471`	`471`	`}`
`472`	`472`	`long numBytes = writer.getNumBytesWritten();`
`473`		`- partitionLengths[partition] = numBytes;`
`474`	`473`	`writeMetrics.incBytesWritten(numBytes);`
`475`	`474`	`}`
`476`	`475`	`threwException = false;`
`@@ -482,7 +481,6 @@ private void mergeSpillsWithTransferTo(`
`482`	`481`	`Closeables.close(spillInputChannels[i], threwException);`
`483`	`482`	`}`
`484`	`483`	`}`
`485`		`- return partitionLengths;`
`486`	`484`	`}`
`487`	`485`
`488`	`486`	`@Override`