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/06/16 06:24:21 UTC
spark git commit: [SPARK-12552][FOLLOWUP] Fix flaky test for
"o.a.s.deploy.master.MasterSuite.master correctly recover the application"
Repository: spark
Updated Branches:
refs/heads/master 7a3e5dc28 -> 2837b14cd
[SPARK-12552][FOLLOWUP] Fix flaky test for "o.a.s.deploy.master.MasterSuite.master correctly recover the application"
## What changes were proposed in this pull request?
Due to the RPC asynchronous event processing, The test "correctly recover the application" could potentially be failed. The issue could be found in here: https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/78126/testReport/org.apache.spark.deploy.master/MasterSuite/master_correctly_recover_the_application/.
So here fixing this flaky test.
## How was this patch tested?
Existing UT.
CC cloud-fan jiangxb1987 , please help to review, thanks!
Author: jerryshao <ss...@hortonworks.com>
Closes #18321 from jerryshao/SPARK-12552-followup.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/2837b14c
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/2837b14c
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/2837b14c
Branch: refs/heads/master
Commit: 2837b14cdc42f096dce07e383caa30c7469c5d6b
Parents: 7a3e5dc
Author: jerryshao <ss...@hortonworks.com>
Authored: Fri Jun 16 14:24:15 2017 +0800
Committer: Wenchen Fan <we...@databricks.com>
Committed: Fri Jun 16 14:24:15 2017 +0800
----------------------------------------------------------------------
.../test/scala/org/apache/spark/deploy/master/MasterSuite.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/2837b14c/core/src/test/scala/org/apache/spark/deploy/master/MasterSuite.scala
----------------------------------------------------------------------
diff --git a/core/src/test/scala/org/apache/spark/deploy/master/MasterSuite.scala b/core/src/test/scala/org/apache/spark/deploy/master/MasterSuite.scala
index 6bb0eec..a223212 100644
--- a/core/src/test/scala/org/apache/spark/deploy/master/MasterSuite.scala
+++ b/core/src/test/scala/org/apache/spark/deploy/master/MasterSuite.scala
@@ -214,7 +214,7 @@ class MasterSuite extends SparkFunSuite
master.rpcEnv.setupEndpoint(Master.ENDPOINT_NAME, master)
// Wait until Master recover from checkpoint data.
eventually(timeout(5 seconds), interval(100 milliseconds)) {
- master.idToApp.size should be(1)
+ master.workers.size should be(1)
}
master.idToApp.keySet should be(Set(fakeAppInfo.id))
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org