Fix test failed

apache · Feb 5, 2015 · bccd515 · bccd515
1 parent 8e77408
commit bccd515
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala b/core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala
@@ -85,7 +85,7 @@ private[spark] class HeartbeatReceiver(sc: SparkContext, scheduler: TaskSchedule
       if (lastSeenMs < minSeenTime) {
         logWarning("Removing Executor " + executorId + " with no recent heartbeats: "
           + (now - lastSeenMs) + " ms exceeds " + slaveTimeout + "ms")
-        scheduler.executorLost(executorId, SlaveLost)
+        scheduler.executorLost(executorId, SlaveLost())
         sc.killExecutor(executorId)
         executorLastSeen.remove(executorId)
       }