Skip to content

Commit d3754d1

Browse files
committed
[SPARK-6980] Added akkaConf to prevent dead letter logging
1 parent 995d196 commit d3754d1

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

core/src/test/scala/org/apache/spark/rpc/akka/AkkaRpcEnvSuite.scala

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,8 @@ import scala.language.postfixOps
2525
import akka.actor.{ActorSystem, Actor, Props}
2626
import akka.pattern.ask
2727

28+
import com.typesafe.config.{ConfigValueFactory, ConfigFactory}
29+
2830
import org.apache.spark.rpc._
2931
import org.apache.spark.{SecurityManager, SparkConf}
3032

@@ -65,7 +67,9 @@ class AkkaRpcEnvSuite extends RpcEnvSuite {
6567
}
6668
}
6769

68-
val system = ActorSystem("EchoSystem")
70+
val akkaConf = ConfigFactory.empty().withValue("akka.log-dead-letters",
71+
ConfigValueFactory.fromAnyRef("off"))
72+
val system = ActorSystem("EchoSystem", akkaConf)
6973
val echoActor = system.actorOf(Props(new EchoActor(0)), name = "echo")
7074
val sleepyActor = system.actorOf(Props(new EchoActor(50)), name = "sleepy")
7175

0 commit comments

Comments
 (0)