Skip to content

Commit

Permalink
fix registered blockmanager again and again
Browse files Browse the repository at this point in the history
  • Loading branch information
cenyuhai committed Sep 15, 2016
1 parent 4b460e2 commit 9839193
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -137,6 +137,7 @@ private[spark] class HeartbeatReceiver(sc: SparkContext, clock: Clock)
// after we just removed it. It's not really an error condition so we should
// not log warning here. Otherwise there may be a lot of noise especially if
// we explicitly remove executors (SPARK-4134).
executorLastSeen(executorId) = clock.getTimeMillis()
logDebug(s"Received heartbeat from unknown executor $executorId")
context.reply(HeartbeatResponse(reregisterBlockManager = true))
}
Expand Down

0 comments on commit 9839193

Please sign in to comment.