Skip to content
Snippets Groups Projects
Commit 9be79458 authored by 10087686's avatar 10087686 Committed by Sean Owen
Browse files

[SPARK-21006][TESTS] Create rpcEnv and run later needs shutdown and awaitTermination

Signed-off-by: 10087686 <wang.jiaochunzte.com.cn>

## What changes were proposed in this pull request?
When  run test("port conflict") case, we need run anotherEnv.shutdown() and anotherEnv.awaitTermination() for free resource.
(Please fill in changes proposed in this fix)

## How was this patch tested?
run RpcEnvSuit.scala Utest
(Please explain how this patch was tested. E.g. unit tests, integration tests, manual tests)
(If this patch involves UI changes, please attach a screenshot; otherwise, remove this)

Please review http://spark.apache.org/contributing.html before opening a pull request.

Author: 10087686 <wang.jiaochun@zte.com.cn>

Closes #18226 from wangjiaochun/master.
parent 847efe12
No related branches found
No related tags found
No related merge requests found
......@@ -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 = {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment