Skip to content

Commit 4f07174

Browse files
committed
Fix unit tests
1 parent 1c2cf26 commit 4f07174

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

core/src/test/scala/org/apache/spark/SparkConfSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -227,7 +227,7 @@ class SparkConfSuite extends FunSuite with LocalSparkContext with ResetSystemPro
227227
test("akka deprecated configs") {
228228
val conf = new SparkConf()
229229

230-
assert(!conf.contains("spark.rpc.num.retries"))
230+
assert(!conf.contains("spark.rpc.numRetries"))
231231
assert(!conf.contains("spark.rpc.retry.wait"))
232232
assert(!conf.contains("spark.rpc.askTimeout"))
233233
assert(!conf.contains("spark.rpc.lookupTimeout"))

core/src/test/scala/org/apache/spark/rpc/RpcEnvSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -156,7 +156,7 @@ abstract class RpcEnvSuite extends FunSuite with BeforeAndAfterAll {
156156

157157
val conf = new SparkConf()
158158
conf.set("spark.rpc.retry.wait", "0")
159-
conf.set("spark.rpc.num.retries", "1")
159+
conf.set("spark.rpc.numRetries", "1")
160160
val anotherEnv = createRpcEnv(conf, "remote", 13345)
161161
// Use anotherEnv to find out the RpcEndpointRef
162162
val rpcEndpointRef = anotherEnv.setupEndpointRef("local", env.address, "ask-timeout")

0 commit comments

Comments
 (0)