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")