aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorShixiong Zhu <shixiong@databricks.com>2016-05-19 12:32:26 -0700
committerShixiong Zhu <shixiong@databricks.com>2016-05-19 12:36:44 -0700
commit305263954a077d4e56dd1a6b2f493949a9973f55 (patch)
tree25044d7d20b113207ae549f0688bbf46e81efa4f
parent5ccecc078aa757d3f1f6632aa6df5659490f602f (diff)
downloadspark-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.scala10
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)