We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7b8b1fa commit c2afd63Copy full SHA for c2afd63
core/src/test/scala/org/apache/spark/scheduler/SparkListenerSuite.scala
@@ -531,7 +531,7 @@ class SparkListenerSuite extends SparkFunSuite with LocalSparkContext with Match
531
532
Seq(true, false).foreach { throwInterruptedException =>
533
val suffix = if (throwInterruptedException) "throw interrupt" else "set Thread interrupted"
534
- test(s"SPARK-30285: Fix race condition in AsyncEventQueue.removeListenerOnError: $suffix") {
+ test(s"SPARK-30285: Fix deadlock in AsyncEventQueue.removeListenerOnError: $suffix") {
535
val conf = new SparkConf(false)
536
.set(LISTENER_BUS_EVENT_QUEUE_CAPACITY, 5)
537
val bus = new LiveListenerBus(conf)
0 commit comments