From daf4ae72fe01b6d9631bfbd061b3846bdf668dfa Mon Sep 17 00:00:00 2001
From: Kan Zhang <kzhang@apache.org>
Date: Thu, 14 May 2015 23:50:50 -0700
Subject: [PATCH] [CORE] Remove unreachable Heartbeat message from Worker
It doesn't look to me Heartbeat is sent to Worker from anyone.
Author: Kan Zhang <kzhang@apache.org>
Closes #6163 from kanzhang/deadwood and squashes the following commits:
56be118 [Kan Zhang] [core] Remove unreachable Heartbeat message from Worker
---
.../src/main/scala/org/apache/spark/deploy/worker/Worker.scala | 3 ---
1 file changed, 3 deletions(-)
diff --git a/core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala b/core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala
index 8f3cc54051..c8df024dda 100755
--- a/core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala
+++ b/core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala
@@ -324,9 +324,6 @@ private[worker] class Worker(
map(e => new ExecutorDescription(e.appId, e.execId, e.cores, e.state))
sender ! WorkerSchedulerStateResponse(workerId, execs.toList, drivers.keys.toSeq)
- case Heartbeat =>
- logInfo(s"Received heartbeat from driver ${sender.path}")
-
case RegisterWorkerFailed(message) =>
if (!registered) {
logError("Worker registration failed: " + message)
--
GitLab