Skip to content

Commit 8b73701

Browse files
committed
Fix rebase issues
1 parent e035105 commit 8b73701

File tree

2 files changed

+3
-4
lines changed

2 files changed

+3
-4
lines changed

core/src/main/scala/org/apache/spark/shuffle/sort/SortShuffleReader.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -164,8 +164,8 @@ private[spark] class SortShuffleReader[K, C](
164164
MergeUtil.mergeSort(finalItrGroup, keyComparator, dep.keyOrdering, dep.aggregator)
165165

166166
// Update the spill metrics and do cleanup work when task is finished.
167-
context.taskMetrics().memoryBytesSpilled += memoryBytesSpilled
168-
context.taskMetrics().diskBytesSpilled += diskBytesSpilled
167+
context.taskMetrics().incMemoryBytesSpilled(memoryBytesSpilled)
168+
context.taskMetrics().incDiskBytesSpilled(diskBytesSpilled)
169169

170170
def releaseFinalShuffleMemory(): Unit = {
171171
inMemoryBlocks.foreach { block =>

core/src/test/scala/org/apache/spark/rdd/RDDSuite.scala

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,9 +23,8 @@ import scala.collection.mutable.{ArrayBuffer, HashMap}
2323
import scala.collection.JavaConverters._
2424
import scala.reflect.ClassTag
2525

26-
import org.scalatest.FunSuite
27-
2826
import com.esotericsoftware.kryo.KryoException
27+
import org.scalatest.FunSuite
2928

3029
import org.apache.spark._
3130
import org.apache.spark.api.java.{JavaRDD, JavaSparkContext}

0 commit comments

Comments
 (0)