From 4e6b4db4ab34ff5331438325596ddd579829635c Mon Sep 17 00:00:00 2001 From: Michael Gummelt Date: Wed, 10 Feb 2016 18:16:25 -0800 Subject: [PATCH] remove flaky test --- .../cluster/mesos/CoarseMesosSchedulerBackendSuite.scala | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/core/src/test/scala/org/apache/spark/scheduler/cluster/mesos/CoarseMesosSchedulerBackendSuite.scala b/core/src/test/scala/org/apache/spark/scheduler/cluster/mesos/CoarseMesosSchedulerBackendSuite.scala index e542aa0cfc4d..b5722f63bb09 100644 --- a/core/src/test/scala/org/apache/spark/scheduler/cluster/mesos/CoarseMesosSchedulerBackendSuite.scala +++ b/core/src/test/scala/org/apache/spark/scheduler/cluster/mesos/CoarseMesosSchedulerBackendSuite.scala @@ -300,6 +300,11 @@ class CoarseMesosSchedulerBackendSuite extends SparkFunSuite override protected def createDriverEndpointRef( properties: ArrayBuffer[(String, String)]): RpcEndpointRef = endpoint + // override to avoid race condition with the driver thread on `mesosDriver` + override def startScheduler(newDriver: SchedulerDriver): Unit = { + mesosDriver = newDriver + } + markRegistered() } backend.start()