File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
core/src/main/java/org/apache/spark/shuffle/sort Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -447,7 +447,7 @@ private void mergeSpillsWithTransferTo(
447447 spillInputChannels [i ] = new FileInputStream (spills [i ].file ).getChannel ();
448448 }
449449 for (int partition = 0 ; partition < numPartitions ; partition ++) {
450- boolean copyThrewExecption = true ;
450+ boolean copyThrewException = true ;
451451 ShufflePartitionWriter writer = mapWriter .getPartitionWriter (partition );
452452 WritableByteChannelWrapper resolvedChannel = writer .openChannelWrapper ()
453453 .orElseGet (() -> new StreamFallbackChannelWrapper (openStreamUnchecked (writer )));
@@ -461,12 +461,12 @@ private void mergeSpillsWithTransferTo(
461461 resolvedChannel .channel (),
462462 spillInputChannelPositions [i ],
463463 partitionLengthInSpill );
464- copyThrewExecption = false ;
464+ copyThrewException = false ;
465465 spillInputChannelPositions [i ] += partitionLengthInSpill ;
466466 writeMetrics .incWriteTime (System .nanoTime () - writeStartTime );
467467 }
468468 } finally {
469- Closeables .close (resolvedChannel , copyThrewExecption );
469+ Closeables .close (resolvedChannel , copyThrewException );
470470 }
471471 long numBytes = writer .getNumBytesWritten ();
472472 writeMetrics .incBytesWritten (numBytes );
You can’t perform that action at this time.
0 commit comments