Skip to content

Commit 74911b7

Browse files
committed
Avoid copy call when constructing TaskKilled.
1 parent 59c2807 commit 74911b7

1 file changed

Lines changed: 1 addition & 3 deletions

File tree

core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1883,9 +1883,7 @@ class DAGSchedulerSuite extends SparkFunSuite with LocalSparkContext with TimeLi
18831883
val accumUpdates2 = Seq(accUpdate3)
18841884
val accumInfo2 = accumUpdates2.map(AccumulatorSuite.makeInfo)
18851885

1886-
val taskKilled = new TaskKilled(
1887-
"test",
1888-
accumInfo2).copy(accums = accumUpdates2)
1886+
val taskKilled = new TaskKilled( "test", accumInfo2, accums = accumUpdates2)
18891887
runEvent(makeCompletionEvent(taskSets.head.tasks.head, taskKilled, "result"))
18901888

18911889
assert(AccumulatorContext.get(acc3.id).get.value === 18L)

0 commit comments

Comments
 (0)