Skip to content

Commit

Permalink
Fix test failed
Browse files Browse the repository at this point in the history
  • Loading branch information
shenh062326 committed Feb 5, 2015
1 parent fb5df97 commit e197e20
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -84,7 +84,7 @@ private[spark] class HeartbeatReceiver(sc: SparkContext, scheduler: TaskSchedule
for ((executorId, lastSeenMs) <- executorLastSeen) {
if (lastSeenMs < minSeenTime) {
logWarning("Removing Executor " + executorId + " with no recent heartbeats: "
+(now - lastSeenMs) + "ms exceeds " + slaveTimeout + "ms")
+ (now - lastSeenMs) + "ms exceeds " + slaveTimeout + "ms")
scheduler.executorLost(executorId, SlaveLost)
sc.killExecutor(executorId)
executorLastSeen.remove(executorId)
Expand Down

0 comments on commit e197e20

Please sign in to comment.