diff options
author | Michael Gummelt <mgummelt@mesosphere.io> | 2016-02-12 15:00:39 -0800 |
---|---|---|
committer | Andrew Or <andrew@databricks.com> | 2016-02-12 15:00:39 -0800 |
commit | 62b1c07e7e88fe9c951c59cf022dfd52f160cfeb (patch) | |
tree | d196f1ee3c7ab284d3a76b18ce0cccb8f1f83268 /core | |
parent | 38bc6018e922877fdf43c90b24cc0438262eb157 (diff) | |
download | spark-62b1c07e7e88fe9c951c59cf022dfd52f160cfeb.tar.gz spark-62b1c07e7e88fe9c951c59cf022dfd52f160cfeb.tar.bz2 spark-62b1c07e7e88fe9c951c59cf022dfd52f160cfeb.zip |
[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 <mgummelt@mesosphere.io>
Closes #11164 from mgummelt/fix_mesos_tests.
Diffstat (limited to 'core')
-rw-r--r-- | core/src/test/scala/org/apache/spark/scheduler/cluster/mesos/CoarseMesosSchedulerBackendSuite.scala | 5 |
1 files changed, 5 insertions, 0 deletions
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 5e01d95fc3..5db7535d36 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() |