From d3754d1916db159eec4d287d63abb4b987592875 Mon Sep 17 00:00:00 2001 From: Bryan Cutler Date: Thu, 11 Jun 2015 15:38:08 -0700 Subject: [PATCH] [SPARK-6980] Added akkaConf to prevent dead letter logging --- .../scala/org/apache/spark/rpc/akka/AkkaRpcEnvSuite.scala | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/core/src/test/scala/org/apache/spark/rpc/akka/AkkaRpcEnvSuite.scala b/core/src/test/scala/org/apache/spark/rpc/akka/AkkaRpcEnvSuite.scala index b72b15bd68102..faab3c29884ee 100644 --- a/core/src/test/scala/org/apache/spark/rpc/akka/AkkaRpcEnvSuite.scala +++ b/core/src/test/scala/org/apache/spark/rpc/akka/AkkaRpcEnvSuite.scala @@ -25,6 +25,8 @@ import scala.language.postfixOps import akka.actor.{ActorSystem, Actor, Props} import akka.pattern.ask +import com.typesafe.config.{ConfigValueFactory, ConfigFactory} + import org.apache.spark.rpc._ import org.apache.spark.{SecurityManager, SparkConf} @@ -65,7 +67,9 @@ class AkkaRpcEnvSuite extends RpcEnvSuite { } } - val system = ActorSystem("EchoSystem") + val akkaConf = ConfigFactory.empty().withValue("akka.log-dead-letters", + ConfigValueFactory.fromAnyRef("off")) + val system = ActorSystem("EchoSystem", akkaConf) val echoActor = system.actorOf(Props(new EchoActor(0)), name = "echo") val sleepyActor = system.actorOf(Props(new EchoActor(50)), name = "sleepy")