diff options
Diffstat (limited to 'core/src/test/scala/org/apache/spark/scheduler/TaskContextSuite.scala')
| -rw-r--r-- | core/src/test/scala/org/apache/spark/scheduler/TaskContextSuite.scala | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/core/src/test/scala/org/apache/spark/scheduler/TaskContextSuite.scala b/core/src/test/scala/org/apache/spark/scheduler/TaskContextSuite.scala index bda4c996b2..d55f6f60ec 100644 --- a/core/src/test/scala/org/apache/spark/scheduler/TaskContextSuite.scala +++ b/core/src/test/scala/org/apache/spark/scheduler/TaskContextSuite.scala @@ -148,8 +148,8 @@ class TaskContextSuite extends SparkFunSuite with BeforeAndAfter with LocalSpark sc = new SparkContext("local[1,4]", "test") val param = AccumulatorParam.LongAccumulatorParam // Create 2 accumulators, one that counts failed values and another that doesn't - val acc1 = new Accumulator(0L, param, Some("x"), internal = false, countFailedValues = true) - val acc2 = new Accumulator(0L, param, Some("y"), internal = false, countFailedValues = false) + val acc1 = new Accumulator(0L, param, Some("x"), countFailedValues = true) + val acc2 = new Accumulator(0L, param, Some("y"), countFailedValues = false) // Fail first 3 attempts of every task. This means each task should be run 4 times. sc.parallelize(1 to 10, 10).map { i => acc1 += 1 @@ -169,8 +169,8 @@ class TaskContextSuite extends SparkFunSuite with BeforeAndAfter with LocalSpark test("failed tasks collect only accumulators whose values count during failures") { sc = new SparkContext("local", "test") val param = AccumulatorParam.LongAccumulatorParam - val acc1 = new Accumulator(0L, param, Some("x"), internal = false, countFailedValues = true) - val acc2 = new Accumulator(0L, param, Some("y"), internal = false, countFailedValues = false) + val acc1 = new Accumulator(0L, param, Some("x"), countFailedValues = true) + val acc2 = new Accumulator(0L, param, Some("y"), countFailedValues = false) // Create a dummy task. We won't end up running this; we just want to collect // accumulator updates from it. val taskMetrics = new TaskMetrics |