diff --git a/core/src/test/scala/org/apache/spark/api/python/PythonWorkerFactorySuite.scala b/core/src/test/scala/org/apache/spark/api/python/PythonWorkerFactorySuite.scala index 34c10bd95ed75..359b76c87a2a5 100644 --- a/core/src/test/scala/org/apache/spark/api/python/PythonWorkerFactorySuite.scala +++ b/core/src/test/scala/org/apache/spark/api/python/PythonWorkerFactorySuite.scala @@ -25,15 +25,13 @@ import scala.concurrent.ExecutionContext.Implicits.global import scala.concurrent.Future import scala.concurrent.duration._ -import org.scalatest.matchers.must.Matchers - import org.apache.spark.SharedSparkContext import org.apache.spark.SparkException import org.apache.spark.SparkFunSuite import org.apache.spark.util.ThreadUtils // Tests for PythonWorkerFactory. -class PythonWorkerFactorySuite extends SparkFunSuite with Matchers with SharedSparkContext { +class PythonWorkerFactorySuite extends SparkFunSuite with SharedSparkContext { test("createSimpleWorker() fails with a timeout error if worker does not connect back") { // It verifies that server side times out in accept(), if the worker does not connect back.