diff options
author | Shixiong Zhu <shixiong@databricks.com> | 2016-05-19 12:32:26 -0700 |
---|---|---|
committer | Shixiong Zhu <shixiong@databricks.com> | 2016-05-19 12:36:44 -0700 |
commit | 305263954a077d4e56dd1a6b2f493949a9973f55 (patch) | |
tree | 25044d7d20b113207ae549f0688bbf46e81efa4f | |
parent | 5ccecc078aa757d3f1f6632aa6df5659490f602f (diff) | |
download | spark-305263954a077d4e56dd1a6b2f493949a9973f55.tar.gz spark-305263954a077d4e56dd1a6b2f493949a9973f55.tar.bz2 spark-305263954a077d4e56dd1a6b2f493949a9973f55.zip |
Fix the compiler error introduced by #13153 for Scala 2.10
-rw-r--r-- | core/src/test/scala/org/apache/spark/ui/jobs/JobProgressListenerSuite.scala | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/core/src/test/scala/org/apache/spark/ui/jobs/JobProgressListenerSuite.scala b/core/src/test/scala/org/apache/spark/ui/jobs/JobProgressListenerSuite.scala index 6f7c9f282a..1fa9b28edf 100644 --- a/core/src/test/scala/org/apache/spark/ui/jobs/JobProgressListenerSuite.scala +++ b/core/src/test/scala/org/apache/spark/ui/jobs/JobProgressListenerSuite.scala @@ -364,20 +364,20 @@ class JobProgressListenerSuite extends SparkFunSuite with LocalSparkContext with test("drop internal and sql accumulators") { val taskInfo = new TaskInfo(0, 0, 0, 0, "", "", TaskLocality.ANY, false) val internalAccum = - AccumulableInfo(id = 1, name = Some("internal"), None, None, internal = true, false) + AccumulableInfo(id = 1, name = Some("internal"), None, None, true, false, None) val sqlAccum = AccumulableInfo( id = 2, name = Some("sql"), - None, - None, + update = None, + value = None, internal = false, countFailedValues = false, metadata = Some(AccumulatorContext.SQL_ACCUM_IDENTIFIER)) val userAccum = AccumulableInfo( id = 3, name = Some("user"), - None, - None, + update = None, + value = None, internal = false, countFailedValues = false, metadata = None) |