From 652def318e47890bd0a0977dc982cc07f99fb06a Mon Sep 17 00:00:00 2001
From: Josh Rosen <joshrosen@databricks.com>
Date: Fri, 20 Nov 2015 13:17:35 -0800
Subject: [PATCH] [SPARK-11650] Reduce RPC timeouts to speed up slow
AkkaUtilsSuite test
This patch reduces some RPC timeouts in order to speed up the slow "AkkaUtilsSuite.remote fetch ssl on - untrusted server", which used to take two minutes to run.
Author: Josh Rosen <joshrosen@databricks.com>
Closes #9869 from JoshRosen/SPARK-11650.
---
core/src/test/scala/org/apache/spark/util/AkkaUtilsSuite.scala | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/core/src/test/scala/org/apache/spark/util/AkkaUtilsSuite.scala b/core/src/test/scala/org/apache/spark/util/AkkaUtilsSuite.scala
index 61601016e0..0af4b6098b 100644
--- a/core/src/test/scala/org/apache/spark/util/AkkaUtilsSuite.scala
+++ b/core/src/test/scala/org/apache/spark/util/AkkaUtilsSuite.scala
@@ -340,10 +340,11 @@ class AkkaUtilsSuite extends SparkFunSuite with LocalSparkContext with ResetSyst
new MapOutputTrackerMasterEndpoint(rpcEnv, masterTracker, conf))
val slaveConf = sparkSSLConfig()
+ .set("spark.rpc.askTimeout", "5s")
+ .set("spark.rpc.lookupTimeout", "5s")
val securityManagerBad = new SecurityManager(slaveConf)
val slaveRpcEnv = RpcEnv.create("spark-slave", hostname, 0, slaveConf, securityManagerBad)
- val slaveTracker = new MapOutputTrackerWorker(conf)
try {
slaveRpcEnv.setupEndpointRef("spark", rpcEnv.address, MapOutputTracker.ENDPOINT_NAME)
fail("should receive either ActorNotFound or TimeoutException")
--
GitLab