Further simplify checking for Nil.

This commit is contained in:
Stephen Haberman 2013-02-02 13:53:28 -06:00
parent 782187c210
commit 7aba123f0c

View file

@ -176,9 +176,7 @@ class DAGScheduler(taskSched: TaskScheduler) extends TaskSchedulerListener with
def visit(rdd: RDD[_]) {
if (!visited(rdd)) {
visited += rdd
val locs = getCacheLocs(rdd)
val atLeastOneMissing = (0 until rdd.splits.size).exists(locs(_) == Nil)
if (atLeastOneMissing) {
if (getCacheLocs(rdd).contains(Nil)) {
for (dep <- rdd.dependencies) {
dep match {
case shufDep: ShuffleDependency[_,_] =>