From 6e1d2fa7a5dbc247ce69c7576ae92c8a2d0fa4c6 Mon Sep 17 00:00:00 2001 From: Shahid Date: Sat, 17 Nov 2018 04:11:42 +0530 Subject: [PATCH] remove space --- .../org/apache/spark/status/AppStatusListenerSuite.scala | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/core/src/test/scala/org/apache/spark/status/AppStatusListenerSuite.scala b/core/src/test/scala/org/apache/spark/status/AppStatusListenerSuite.scala index e3ec3288f32e8..58fa39418966e 100644 --- a/core/src/test/scala/org/apache/spark/status/AppStatusListenerSuite.scala +++ b/core/src/test/scala/org/apache/spark/status/AppStatusListenerSuite.scala @@ -1276,16 +1276,13 @@ class AppStatusListenerSuite extends SparkFunSuite with BeforeAndAfter { } test("SPARK-25451: total tasks in the executor summary should match total stage tasks") { - val testConf = conf.clone() .set("spark.ui.liveUpdate.period", s"${Int.MaxValue}s") val listener = new AppStatusListener(store, testConf, true) - val stage = new StageInfo(1, 0, "stage1", 4, Nil, Nil, "details1") - + val stage = new StageInfo(1, 0, "stage", 4, Nil, Nil, "details") listener.onJobStart(SparkListenerJobStart(1, time, Seq(stage), null)) - listener.onStageSubmitted(SparkListenerStageSubmitted(stage, new Properties())) val tasks = createTasks(4, Array("1", "2")) @@ -1316,7 +1313,6 @@ class AppStatusListenerSuite extends SparkFunSuite with BeforeAndAfter { } val esummary = store.view(classOf[ExecutorStageSummaryWrapper]).asScala.map(_.info) - esummary.foreach { execSummary => assert(execSummary.failedTasks == 2) }