Skip to content

Commit 66ae245

Browse files
committed
Return immutableSet
1 parent a11cdd9 commit 66ae245

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,8 @@ import java.util.concurrent.TimeUnit
2323
import java.util.concurrent.atomic.AtomicInteger
2424

2525
import scala.collection.Map
26-
import scala.collection.mutable.{HashMap, HashSet, Set, Stack}
26+
import scala.collection.immutable.Set
27+
import scala.collection.mutable.{HashMap, HashSet, Stack}
2728
import scala.concurrent.duration._
2829
import scala.language.existentials
2930
import scala.language.postfixOps
@@ -427,7 +428,7 @@ class DAGScheduler(
427428
while (waitingForVisit.nonEmpty) {
428429
visit(waitingForVisit.pop())
429430
}
430-
parents
431+
parents.toSet
431432
}
432433

433434
private def getMissingParentStages(stage: Stage): List[Stage] = {

0 commit comments

Comments
 (0)