[SPARK-6980] Added akkaConf to prevent dead letter logging

tdas · Jun 11, 2015 · d3754d1 · d3754d1
1 parent 995d196
commit d3754d1
Showing 1 changed file with 5 additions and 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
@@ -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")