diff --git a/core/src/main/scala/spark/DAGScheduler.scala b/core/src/main/scala/spark/DAGScheduler.scala index 423510d883229b7b49ca31e86fbc397c7ce7e0c7..1b4af9d84c6d2159eb05084e2587ddef62a6bed1 100644 --- a/core/src/main/scala/spark/DAGScheduler.scala +++ b/core/src/main/scala/spark/DAGScheduler.scala @@ -363,7 +363,7 @@ private trait DAGScheduler extends Scheduler with Logging { val endTime = System.currentTimeMillis() + timeout // TODO: Use pluggable clock for testing while (eventQueues(runId).isEmpty) { val time = System.currentTimeMillis() - if (time > endTime) { + if (time >= endTime) { return None } else { lock.wait(endTime - time)