You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by we...@apache.org on 2017/08/09 10:45:45 UTC
spark git commit: [SPARK-21663][TESTS] test("remote fetch below max
RPC message size") should call masterTracker.stop() in MapOutputTrackerSuite
Repository: spark
Updated Branches:
refs/heads/master b35660dd0 -> 6426adffa
[SPARK-21663][TESTS] test("remote fetch below max RPC message size") should call masterTracker.stop() in MapOutputTrackerSuite
Signed-off-by: 10087686 <wang.jiaochunzte.com.cn>
## What changes were proposed in this pull request?
After Unit tests end，there should be call masterTracker.stop() to free resource;
(Please fill in changes proposed in this fix)
## How was this patch tested?
Run Unit tests;
(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 <wa...@zte.com.cn>
Closes #18867 from wangjiaochun/mapout.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/6426adff
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/6426adff
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/6426adff
Branch: refs/heads/master
Commit: 6426adffaf152651c30d481bb925d5025fd6130a
Parents: b35660d
Author: 10087686 <wa...@zte.com.cn>
Authored: Wed Aug 9 18:45:38 2017 +0800
Committer: Wenchen Fan <we...@databricks.com>
Committed: Wed Aug 9 18:45:38 2017 +0800
----------------------------------------------------------------------
.../src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/6426adff/core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala
----------------------------------------------------------------------
diff --git a/core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala b/core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala
index bc3d23e..493ae51 100644
--- a/core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala
+++ b/core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala
@@ -176,7 +176,8 @@ class MapOutputTrackerSuite extends SparkFunSuite {
val masterTracker = newTrackerMaster(newConf)
val rpcEnv = createRpcEnv("spark")
val masterEndpoint = new MapOutputTrackerMasterEndpoint(rpcEnv, masterTracker, newConf)
- rpcEnv.setupEndpoint(MapOutputTracker.ENDPOINT_NAME, masterEndpoint)
+ masterTracker.trackerEndpoint =
+ rpcEnv.setupEndpoint(MapOutputTracker.ENDPOINT_NAME, masterEndpoint)
// Message size should be ~123B, and no exception should be thrown
masterTracker.registerShuffle(10, 1)
@@ -191,7 +192,7 @@ class MapOutputTrackerSuite extends SparkFunSuite {
verify(rpcCallContext, timeout(30000)).reply(any())
assert(0 == masterTracker.getNumCachedSerializedBroadcast)
-// masterTracker.stop() // this throws an exception
+ masterTracker.stop()
rpcEnv.shutdown()
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org