Fixes a nasty bug that could happen when tasks fail, because calling

wait() with a timeout of 0 on a Java object means "wait forever".
This commit is contained in:
Matei Zaharia 2012-03-01 13:43:17 -08:00
Родитель 1e10df0a46
Коммит 97eee50825
1 изменённых файлов: 1 добавлений и 1 удалений

Просмотреть файл

@ -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)