diff options
| author | Isaias Barroso <isaias.barroso@gmail.com> | 2015-04-15 22:40:52 +0100 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2015-04-15 22:40:52 +0100 |
| commit | d5f1b9650b6e46cf6a9d61f01cda0df0cda5b1c9 (patch) | |
| tree | 3c8f92a5fef2bd411dc83db9eba9d83286517f73 /core | |
| parent | 585638e81ce09a72b9e7f95d38e0d432cfa02456 (diff) | |
| download | spark-d5f1b9650b6e46cf6a9d61f01cda0df0cda5b1c9.tar.gz spark-d5f1b9650b6e46cf6a9d61f01cda0df0cda5b1c9.tar.bz2 spark-d5f1b9650b6e46cf6a9d61f01cda0df0cda5b1c9.zip | |
[SPARK-2312] Logging Unhandled messages
The previous solution has changed based on https://github.com/apache/spark/pull/2048 discussions.
Author: Isaias Barroso <isaias.barroso@gmail.com>
Closes #2055 from isaias/SPARK-2312 and squashes the following commits:
f61d9e6 [Isaias Barroso] Change Log level for unhandled message to debug
f341777 [Isaias Barroso] [SPARK-2312] Logging Unhandled messages
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/util/ActorLogReceive.scala | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/util/ActorLogReceive.scala b/core/src/main/scala/org/apache/spark/util/ActorLogReceive.scala index 332d0cbb2d..81a7cbde01 100644 --- a/core/src/main/scala/org/apache/spark/util/ActorLogReceive.scala +++ b/core/src/main/scala/org/apache/spark/util/ActorLogReceive.scala @@ -43,7 +43,13 @@ private[spark] trait ActorLogReceive { private val _receiveWithLogging = receiveWithLogging - override def isDefinedAt(o: Any): Boolean = _receiveWithLogging.isDefinedAt(o) + override def isDefinedAt(o: Any): Boolean = { + val handled = _receiveWithLogging.isDefinedAt(o) + if (!handled) { + log.debug(s"Received unexpected actor system event: $o") + } + handled + } override def apply(o: Any): Unit = { if (log.isDebugEnabled) { |