Repository: spark Updated Branches: refs/heads/branch-1.6 a529427a1 -> 1a5dfb706
[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/1a5dfb70 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/1a5dfb70 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/1a5dfb70 Branch: refs/heads/branch-1.6 Commit: 1a5dfb706f9188ff6734aad81d622376be3756d1 Parents: a529427 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:39 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/1a5dfb70/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 3fad595..059a7e1 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) } } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
