Skip to content

Commit d5f1b96

Browse files
isaiassrowen
authored andcommitted
[SPARK-2312] Logging Unhandled messages
The previous solution has changed based on apache#2048 discussions. Author: Isaias Barroso <[email protected]> Closes apache#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
1 parent 585638e commit d5f1b96

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

core/src/main/scala/org/apache/spark/util/ActorLogReceive.scala

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,13 @@ private[spark] trait ActorLogReceive {
4343

4444
private val _receiveWithLogging = receiveWithLogging
4545

46-
override def isDefinedAt(o: Any): Boolean = _receiveWithLogging.isDefinedAt(o)
46+
override def isDefinedAt(o: Any): Boolean = {
47+
val handled = _receiveWithLogging.isDefinedAt(o)
48+
if (!handled) {
49+
log.debug(s"Received unexpected actor system event: $o")
50+
}
51+
handled
52+
}
4753

4854
override def apply(o: Any): Unit = {
4955
if (log.isDebugEnabled) {

0 commit comments

Comments
 (0)