Repository: spark
Updated Branches:
  refs/heads/branch-1.5 cf36cdba2 -> bdcbbdac6


[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 <[email protected]>

Closes #9772 from vanzin/SPARK-11786.

(cherry picked from commit 936bc0bcbf957fa1d7cb5cfe88d628c830df5981)
Signed-off-by: Marcelo Vanzin <[email protected]>


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/bdcbbdac
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/bdcbbdac
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/bdcbbdac

Branch: refs/heads/branch-1.5
Commit: bdcbbdac636e476717593044e0ca77631bbaba2d
Parents: cf36cdb
Author: Marcelo Vanzin <[email protected]>
Authored: Tue Nov 17 14:23:28 2015 -0800
Committer: Marcelo Vanzin <[email protected]>
Committed: Tue Nov 17 14:23:57 2015 -0800

----------------------------------------------------------------------
 core/src/main/scala/org/apache/spark/rpc/akka/AkkaRpcEnv.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/spark/blob/bdcbbdac/core/src/main/scala/org/apache/spark/rpc/akka/AkkaRpcEnv.scala
----------------------------------------------------------------------
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 fc17542..76759c4 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
@@ -267,7 +267,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)
   }
 }
 


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to