From 4d9112fcacce3dfa869514e1a16bad6bb09e1be7 Mon Sep 17 00:00:00 2001
From: Cheena Budhiraja <110803195+bcheena@users.noreply.github.com>
Date: Thu, 13 Feb 2025 14:41:49 +0530
Subject: [PATCH] Cancel the Timer non-daemon thread on stopping the
 BarrierCoordinator

---
 core/src/main/scala/org/apache/spark/BarrierCoordinator.scala | 1 +
 1 file changed, 1 insertion(+)

diff --git a/core/src/main/scala/org/apache/spark/BarrierCoordinator.scala b/core/src/main/scala/org/apache/spark/BarrierCoordinator.scala
index 8ffccdf664b2d..a0db3ff8bfcaf 100644
--- a/core/src/main/scala/org/apache/spark/BarrierCoordinator.scala
+++ b/core/src/main/scala/org/apache/spark/BarrierCoordinator.scala
@@ -77,6 +77,7 @@ private[spark] class BarrierCoordinator(
       states.forEachValue(1, clearStateConsumer)
       states.clear()
       listenerBus.removeListener(listener)
+      timer.cancel()
     } finally {
       super.onStop()
     }