diff options
| author | Josh Rosen <joshrosen@databricks.com> | 2015-11-20 13:17:35 -0800 |
|---|---|---|
| committer | Josh Rosen <joshrosen@databricks.com> | 2015-11-20 13:17:35 -0800 |
| commit | 652def318e47890bd0a0977dc982cc07f99fb06a (patch) | |
| tree | 7db1c564beaf4ec618a836602e307cfef068cae2 | |
| parent | 3b9d2a347f9c796b90852173d84189834e499e25 (diff) | |
| download | spark-652def318e47890bd0a0977dc982cc07f99fb06a.tar.gz spark-652def318e47890bd0a0977dc982cc07f99fb06a.tar.bz2 spark-652def318e47890bd0a0977dc982cc07f99fb06a.zip | |
[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.
| -rw-r--r-- | core/src/test/scala/org/apache/spark/util/AkkaUtilsSuite.scala | 3 |
1 files changed, 2 insertions, 1 deletions
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") |