From 2e5f9a8c35541286d0d52d0eaa3c862db2bfe808 Mon Sep 17 00:00:00 2001 From: 10087686 Date: Wed, 7 Jun 2017 15:59:51 +0800 Subject: [PATCH] =?UTF-8?q?Create=20rpcEnv=20and=20run=20later=20needs=20s?= =?UTF-8?q?hutdown=20and=20awaitTermination=EF=88=90=20Signed-off-by:=2010?= =?UTF-8?q?087686=20?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- core/src/test/scala/org/apache/spark/rpc/RpcEnvSuite.scala | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/core/src/test/scala/org/apache/spark/rpc/RpcEnvSuite.scala b/core/src/test/scala/org/apache/spark/rpc/RpcEnvSuite.scala index 31d9dd3de8acc..59d8c14d74e30 100644 --- a/core/src/test/scala/org/apache/spark/rpc/RpcEnvSuite.scala +++ b/core/src/test/scala/org/apache/spark/rpc/RpcEnvSuite.scala @@ -633,7 +633,12 @@ abstract class RpcEnvSuite extends SparkFunSuite with BeforeAndAfterAll { test("port conflict") { val anotherEnv = createRpcEnv(new SparkConf(), "remote", env.address.port) - assert(anotherEnv.address.port != env.address.port) + try { + assert(anotherEnv.address.port != env.address.port) + } finally { + anotherEnv.shutdown() + anotherEnv.awaitTermination() + } } private def testSend(conf: SparkConf): Unit = {