From 2837b14cdc42f096dce07e383caa30c7469c5d6b Mon Sep 17 00:00:00 2001
From: jerryshao <sshao@hortonworks.com>
Date: Fri, 16 Jun 2017 14:24:15 +0800
Subject: [PATCH] [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 <sshao@hortonworks.com>
Closes #18321 from jerryshao/SPARK-12552-followup.
---
.../test/scala/org/apache/spark/deploy/master/MasterSuite.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 6bb0eec040..a223212678 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))
--
GitLab