File tree Expand file tree Collapse file tree 1 file changed +5
-1
lines changed
core/src/test/scala/org/apache/spark/rpc/akka Expand file tree Collapse file tree 1 file changed +5
-1
lines changed Original file line number Diff line number Diff line change @@ -25,6 +25,8 @@ import scala.language.postfixOps
2525import akka .actor .{ActorSystem , Actor , Props }
2626import akka .pattern .ask
2727
28+ import com .typesafe .config .{ConfigValueFactory , ConfigFactory }
29+
2830import org .apache .spark .rpc ._
2931import 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
You can’t perform that action at this time.
0 commit comments