YARN-11588. [Federation] Fix uncleaned threads in yarn router thread …

…pool executor (#6159) Contributed by Jeffrey Chang. Reviewed-by: Inigo Goiri <[email protected]> Signed-off-by: Shilun Fan <[email protected]>
apache · Oct 12, 2023 · bd28ba3 · bd28ba3
1 parent 732d4e7
commit bd28ba3
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/.../main/java/org/apache/hadoop/yarn/server/router/clientrm/FederationClientInterceptor.java b/.../main/java/org/apache/hadoop/yarn/server/router/clientrm/FederationClientInterceptor.java
@@ -230,6 +230,9 @@ public void init(String userName) {
     this.executorService = new ThreadPoolExecutor(numMinThreads, numMaxThreads,
         keepAliveTime, TimeUnit.MILLISECONDS, workQueue, threadFactory);
 
+    // Adding this line so that unused user threads will exit and be cleaned up if idle for too long
+    this.executorService.allowCoreThreadTimeOut(true);
+
     final Configuration conf = this.getConf();
 
     try {