Fix unit tests

apache · Apr 21, 2015 · 4f07174 · 4f07174
1 parent 1c2cf26
commit 4f07174
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/core/src/test/scala/org/apache/spark/SparkConfSuite.scala b/core/src/test/scala/org/apache/spark/SparkConfSuite.scala
@@ -227,7 +227,7 @@ class SparkConfSuite extends FunSuite with LocalSparkContext with ResetSystemPro
   test("akka deprecated configs") {
     val conf = new SparkConf()
 
-    assert(!conf.contains("spark.rpc.num.retries"))
+    assert(!conf.contains("spark.rpc.numRetries"))
     assert(!conf.contains("spark.rpc.retry.wait"))
     assert(!conf.contains("spark.rpc.askTimeout"))
     assert(!conf.contains("spark.rpc.lookupTimeout"))

diff --git a/core/src/test/scala/org/apache/spark/rpc/RpcEnvSuite.scala b/core/src/test/scala/org/apache/spark/rpc/RpcEnvSuite.scala
@@ -156,7 +156,7 @@ abstract class RpcEnvSuite extends FunSuite with BeforeAndAfterAll {
 
     val conf = new SparkConf()
     conf.set("spark.rpc.retry.wait", "0")
-    conf.set("spark.rpc.num.retries", "1")
+    conf.set("spark.rpc.numRetries", "1")
     val anotherEnv = createRpcEnv(conf, "remote", 13345)
     // Use anotherEnv to find out the RpcEndpointRef
     val rpcEndpointRef = anotherEnv.setupEndpointRef("local", env.address, "ask-timeout")