more cleanup of debug garbage

squito · squito · commit 46bc26aadfe1 · 2015-06-11T11:28:33.000-05:00
diff --git a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
@@ -1097,7 +1097,6 @@ class DAGScheduler(
                 {
                   newlyRunnable += shuffleStage
                 }
-                val newlyRunnableWithJob = newlyRunnable.map{x => x -> activeJobForStage(x)}
                 waitingStages --= newlyRunnable
                 runningStages ++= newlyRunnable
                 for {

Original file line number	Diff line number	Diff line change
`@@ -1097,7 +1097,6 @@ class DAGScheduler(`
`1097`	`1097`	`{`
`1098`	`1098`	`newlyRunnable += shuffleStage`
`1099`	`1099`	`}`
`1100`		`- val newlyRunnableWithJob = newlyRunnable.map{x => x -> activeJobForStage(x)}`
`1101`	`1100`	`waitingStages --= newlyRunnable`
`1102`	`1101`	`runningStages ++= newlyRunnable`
`1103`	`1102`	`for {`