You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by pw...@apache.org on 2014/01/06 07:37:46 UTC
[3/4] git commit: Responding to Aaron's review
Responding to Aaron's review
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/675d7eb4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/675d7eb4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/675d7eb4
Branch: refs/heads/master
Commit: 675d7eb4f064129d275a45df4c5c43f558638422
Parents: 94fdcda
Author: Patrick Wendell <pw...@gmail.com>
Authored: Sun Jan 5 21:23:14 2014 -0800
Committer: Patrick Wendell <pw...@gmail.com>
Committed: Sun Jan 5 21:23:14 2014 -0800
----------------------------------------------------------------------
core/src/main/scala/org/apache/spark/util/AkkaUtils.scala | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/675d7eb4/core/src/main/scala/org/apache/spark/util/AkkaUtils.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/util/AkkaUtils.scala b/core/src/main/scala/org/apache/spark/util/AkkaUtils.scala
index 5729334..7df7e3d 100644
--- a/core/src/main/scala/org/apache/spark/util/AkkaUtils.scala
+++ b/core/src/main/scala/org/apache/spark/util/AkkaUtils.scala
@@ -52,6 +52,8 @@ private[spark] object AkkaUtils {
val akkaLogLifecycleEvents = conf.get("spark.akka.logLifecycleEvents", "false").toBoolean
val lifecycleEvents = if (akkaLogLifecycleEvents) "on" else "off"
if (!akkaLogLifecycleEvents) {
+ // As a workaround for Akka issue #3787, we coerce the "EndpointWriter" log to be silent.
+ // See: https://www.assembla.com/spaces/akka/tickets/3787#/
Option(Logger.getLogger("akka.remote.EndpointWriter")).map(l => l.setLevel(Level.FATAL))
}