From c2afd632e6d00f693e626e36ae430ceea5b78c47 Mon Sep 17 00:00:00 2001 From: Wang Shuo Date: Wed, 18 Dec 2019 12:50:20 +0800 Subject: [PATCH] Fix UT --- .../scala/org/apache/spark/scheduler/SparkListenerSuite.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/test/scala/org/apache/spark/scheduler/SparkListenerSuite.scala b/core/src/test/scala/org/apache/spark/scheduler/SparkListenerSuite.scala index 4dbc807b6138e..bf2573b5bd2d3 100644 --- a/core/src/test/scala/org/apache/spark/scheduler/SparkListenerSuite.scala +++ b/core/src/test/scala/org/apache/spark/scheduler/SparkListenerSuite.scala @@ -531,7 +531,7 @@ class SparkListenerSuite extends SparkFunSuite with LocalSparkContext with Match Seq(true, false).foreach { throwInterruptedException => val suffix = if (throwInterruptedException) "throw interrupt" else "set Thread interrupted" - test(s"SPARK-30285: Fix race condition in AsyncEventQueue.removeListenerOnError: $suffix") { + test(s"SPARK-30285: Fix deadlock in AsyncEventQueue.removeListenerOnError: $suffix") { val conf = new SparkConf(false) .set(LISTENER_BUS_EVENT_QUEUE_CAPACITY, 5) val bus = new LiveListenerBus(conf)