Skip to content
Snippets Groups Projects
Commit d5f1b965 authored by Isaias Barroso's avatar Isaias Barroso Committed by Sean Owen
Browse files

[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
parent 585638e8
No related branches found
No related tags found
No related merge requests found
......@@ -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) {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment