diff options
| author | Reynold Xin <rxin@apache.org> | 2014-08-11 15:25:21 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@apache.org> | 2014-08-11 15:25:21 -0700 |
| commit | 37338666655909502e424b4639d680271d6d4c12 (patch) | |
| tree | 816be409334dde9bb9000eb307de2fbbfca8f67a /core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala | |
| parent | db06a81fb7a413faa3fe0f8c35918f70454cb05d (diff) | |
| download | spark-37338666655909502e424b4639d680271d6d4c12.tar.gz spark-37338666655909502e424b4639d680271d6d4c12.tar.bz2 spark-37338666655909502e424b4639d680271d6d4c12.zip | |
[SPARK-2952] Enable logging actor messages at DEBUG level
Example messages:
```
14/08/09 21:37:01 DEBUG BlockManagerMasterActor: [actor] received message RegisterBlockManager(BlockManagerId(0, rxin-mbp, 58092, 0),278302556,Actor[akka.tcp://spark@rxin-mbp:58088/user/BlockManagerActor1#-63596539]) from Actor[akka.tcp://spark@rxin-mbp:58088/temp/$c]
14/08/09 21:37:01 DEBUG BlockManagerMasterActor: [actor] handled message (0.279 ms) RegisterBlockManager(BlockManagerId(0, rxin-mbp, 58092, 0),278302556,Actor[akka.tcp://spark@rxin-mbp:58088/user/BlockManagerActor1#-63596539]) from Actor[akka.tcp://spark@rxin-mbp:58088/temp/$c]
```
cc @mengxr @tdas @pwendell
Author: Reynold Xin <rxin@apache.org>
Closes #1870 from rxin/actorLogging and squashes the following commits:
c531ee5 [Reynold Xin] Added license header for ActorLogReceive.
f6b1ebe [Reynold Xin] [SPARK-2952] Enable logging actor messages at DEBUG level
Diffstat (limited to 'core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala b/core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala index 24ccce21b6..83ae57b7f1 100644 --- a/core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala +++ b/core/src/main/scala/org/apache/spark/HeartbeatReceiver.scala @@ -21,6 +21,7 @@ import akka.actor.Actor import org.apache.spark.executor.TaskMetrics import org.apache.spark.storage.BlockManagerId import org.apache.spark.scheduler.TaskScheduler +import org.apache.spark.util.ActorLogReceive /** * A heartbeat from executors to the driver. This is a shared message used by several internal @@ -36,8 +37,10 @@ private[spark] case class HeartbeatResponse(reregisterBlockManager: Boolean) /** * Lives in the driver to receive heartbeats from executors.. */ -private[spark] class HeartbeatReceiver(scheduler: TaskScheduler) extends Actor { - override def receive = { +private[spark] class HeartbeatReceiver(scheduler: TaskScheduler) + extends Actor with ActorLogReceive with Logging { + + override def receiveWithLogging = { case Heartbeat(executorId, taskMetrics, blockManagerId) => val response = HeartbeatResponse( !scheduler.executorHeartbeatReceived(executorId, taskMetrics, blockManagerId)) |