diff options
| author | Marcelo Vanzin <vanzin@cloudera.com> | 2015-11-17 14:23:28 -0800 |
|---|---|---|
| committer | Marcelo Vanzin <vanzin@cloudera.com> | 2015-11-17 14:23:28 -0800 |
| commit | 936bc0bcbf957fa1d7cb5cfe88d628c830df5981 (patch) | |
| tree | 3c89e54ae7bb7fa965d46f4609234999b8361370 /core | |
| parent | 3e9e6380236985ec5b51b459f8c61f964a76ff8b (diff) | |
| download | spark-936bc0bcbf957fa1d7cb5cfe88d628c830df5981.tar.gz spark-936bc0bcbf957fa1d7cb5cfe88d628c830df5981.tar.bz2 spark-936bc0bcbf957fa1d7cb5cfe88d628c830df5981.zip | |
[SPARK-11786][CORE] Tone down messages from akka error monitor.
There events happen normally during the app's lifecycle, so printing
out ERROR logs all the time is misleading, and can actually affect usability
of interactive shells.
Author: Marcelo Vanzin <vanzin@cloudera.com>
Closes #9772 from vanzin/SPARK-11786.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/rpc/akka/AkkaRpcEnv.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/rpc/akka/AkkaRpcEnv.scala b/core/src/main/scala/org/apache/spark/rpc/akka/AkkaRpcEnv.scala index 3fad595a0d..059a7e10ec 100644 --- a/core/src/main/scala/org/apache/spark/rpc/akka/AkkaRpcEnv.scala +++ b/core/src/main/scala/org/apache/spark/rpc/akka/AkkaRpcEnv.scala @@ -263,7 +263,7 @@ private[akka] class ErrorMonitor extends Actor with ActorLogReceive with Logging } override def receiveWithLogging: Actor.Receive = { - case Error(cause: Throwable, _, _, message: String) => logError(message, cause) + case Error(cause: Throwable, _, _, message: String) => logDebug(message, cause) } } |