remove uneeded type

patrickbrownsync · patrickbrownsync · commit 178f7c3bf82f · 2018-10-29T13:55:38.000-06:00
diff --git a/core/src/main/scala/org/apache/spark/status/AppStatusListener.scala b/core/src/main/scala/org/apache/spark/status/AppStatusListener.scala
@@ -1097,7 +1097,7 @@ private[spark] class AppStatusListener(
     }
 
     // Delete tasks for all stages in one pass, as deleting them for each stage individually is slow
-    val tasks: Iterable[TaskDataWrapper] = kvstore.view(classOf[TaskDataWrapper]).asScala
+    val tasks = kvstore.view(classOf[TaskDataWrapper]).asScala
     val keys = stages.map(s => (s.info.stageId, s.info.attemptId)).toSet
     tasks.foreach { t =>
       if (keys.contains((t.stageId, t.stageAttemptId))) {

Original file line number	Diff line number	Diff line change
`@@ -1097,7 +1097,7 @@ private[spark] class AppStatusListener(`
`1097`	`1097`	`}`
`1098`	`1098`
`1099`	`1099`	`// Delete tasks for all stages in one pass, as deleting them for each stage individually is slow`
`1100`		`- val tasks: Iterable[TaskDataWrapper] = kvstore.view(classOf[TaskDataWrapper]).asScala`
	`1100`	`+ val tasks = kvstore.view(classOf[TaskDataWrapper]).asScala`
`1101`	`1101`	`val keys = stages.map(s => (s.info.stageId, s.info.attemptId)).toSet`
`1102`	`1102`	`tasks.foreach { t =>`
`1103`	`1103`	`if (keys.contains((t.stageId, t.stageAttemptId))) {`