spark-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From van...@apache.org
Subject spark git commit: [SPARK-11786][CORE] Tone down messages from akka error monitor.
Date Tue, 17 Nov 2015 22:23:36 GMT
Repository: spark
Updated Branches:
  refs/heads/master 3e9e63802 -> 936bc0bcb


[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.


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

Branch: refs/heads/master
Commit: 936bc0bcbf957fa1d7cb5cfe88d628c830df5981
Parents: 3e9e638
Author: Marcelo Vanzin <vanzin@cloudera.com>
Authored: Tue Nov 17 14:23:28 2015 -0800
Committer: Marcelo Vanzin <vanzin@cloudera.com>
Committed: Tue Nov 17 14:23:28 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/936bc0bc/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: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org


Mime
View raw message