From 6c9bdd12a80cfe00962d30faa2581e71b4cc7fd2 Mon Sep 17 00:00:00 2001 From: Dongjoon Hyun Date: Thu, 21 Nov 2024 14:03:23 -0800 Subject: [PATCH] [SPARK-50385][CORE] Use class name prefix for REST Submission API thread pool --- .../org/apache/spark/deploy/rest/RestSubmissionServer.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/core/src/main/scala/org/apache/spark/deploy/rest/RestSubmissionServer.scala b/core/src/main/scala/org/apache/spark/deploy/rest/RestSubmissionServer.scala index d3381ef6fb7f1..091807a64d355 100644 --- a/core/src/main/scala/org/apache/spark/deploy/rest/RestSubmissionServer.scala +++ b/core/src/main/scala/org/apache/spark/deploy/rest/RestSubmissionServer.scala @@ -93,6 +93,7 @@ private[spark] abstract class RestSubmissionServer( */ private def doStart(startPort: Int): (Server, Int) = { val threadPool = new QueuedThreadPool(masterConf.get(MASTER_REST_SERVER_MAX_THREADS)) + threadPool.setName(getClass().getSimpleName()) threadPool.setDaemon(true) val server = new Server(threadPool)