From 828e065b1044c0e47caf2207212748a2a05eb65b Mon Sep 17 00:00:00 2001
From: Andrew xia <junluan.xia@intel.com>
Date: Tue, 13 Aug 2013 20:39:29 +0800
Subject: [PATCH] add reviveoffer after tasks finish

---
 .../scala/spark/scheduler/mesos/MesosSchedulerBackend.scala    | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/core/src/main/scala/spark/scheduler/mesos/MesosSchedulerBackend.scala b/core/src/main/scala/spark/scheduler/mesos/MesosSchedulerBackend.scala
index f6069a5775..565c7ac1d5 100644
--- a/core/src/main/scala/spark/scheduler/mesos/MesosSchedulerBackend.scala
+++ b/core/src/main/scala/spark/scheduler/mesos/MesosSchedulerBackend.scala
@@ -286,6 +286,9 @@ private[spark] class MesosSchedulerBackend(
         }
       }
       scheduler.statusUpdate(tid, state, status.getData.asReadOnlyByteBuffer)
+      if (isFinished(status.getState)) {
+        d.reviveOffers()
+      }
     } finally {
       restoreClassLoader(oldClassLoader)
     }