Skip to content

Commit 62b1c07

Browse files
Michael GummeltAndrew Or
authored andcommitted
[SPARK-5095] remove flaky test
Overrode the start() method, which was previously starting a thread causing a race condition. I believe this should fix the flaky test. Author: Michael Gummelt <[email protected]> Closes #11164 from mgummelt/fix_mesos_tests.
1 parent 38bc601 commit 62b1c07

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

core/src/test/scala/org/apache/spark/scheduler/cluster/mesos/CoarseMesosSchedulerBackendSuite.scala

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -300,6 +300,11 @@ class CoarseMesosSchedulerBackendSuite extends SparkFunSuite
300300
override protected def createDriverEndpointRef(
301301
properties: ArrayBuffer[(String, String)]): RpcEndpointRef = endpoint
302302

303+
// override to avoid race condition with the driver thread on `mesosDriver`
304+
override def startScheduler(newDriver: SchedulerDriver): Unit = {
305+
mesosDriver = newDriver
306+
}
307+
303308
markRegistered()
304309
}
305310
backend.start()

0 commit comments

Comments
 (0)