diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2014-01-05 21:23:14 -0800 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2014-01-05 21:23:14 -0800 |
| commit | 675d7eb4f064129d275a45df4c5c43f558638422 (patch) | |
| tree | 1b08dbe0cb444778b825994766267877438c8680 | |
| parent | 94fdcda89638498f127abf3bb5231064182b4945 (diff) | |
| download | spark-675d7eb4f064129d275a45df4c5c43f558638422.tar.gz spark-675d7eb4f064129d275a45df4c5c43f558638422.tar.bz2 spark-675d7eb4f064129d275a45df4c5c43f558638422.zip | |
Responding to Aaron's review
| -rw-r--r-- | core/src/main/scala/org/apache/spark/util/AkkaUtils.scala | 2 |
1 files changed, 2 insertions, 0 deletions
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 5729334e24..7df7e3d8e5 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)) } |