From 4408e38bc61dd16e43c0c98f0bf6c86ce61d37c1 Mon Sep 17 00:00:00 2001 From: Jeremy Dahlgren Date: Fri, 2 May 2025 19:00:40 -0400 Subject: [PATCH] Adjust `ForkJoinPool` prefix in `HdfsClientThreadLeakFilter` (#127534) Adds the ForkJoinPool.commonPool-worker- prefix to the Thread getName().startsWith() checks in HdfsClientThreadLeakFilter. This resolves the "There are still zombie threads that couldn't be terminated" errors in the Hdfs IT tests. Closes #127290 Closes #127289 Closes #127288 Closes #127287 --- .../test/fixtures/hdfs/HdfsClientThreadLeakFilter.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/test/fixtures/hdfs-fixture/src/main/java/org/elasticsearch/test/fixtures/hdfs/HdfsClientThreadLeakFilter.java b/test/fixtures/hdfs-fixture/src/main/java/org/elasticsearch/test/fixtures/hdfs/HdfsClientThreadLeakFilter.java index 81d17841f042..0dc6b23b8540 100644 --- a/test/fixtures/hdfs-fixture/src/main/java/org/elasticsearch/test/fixtures/hdfs/HdfsClientThreadLeakFilter.java +++ b/test/fixtures/hdfs-fixture/src/main/java/org/elasticsearch/test/fixtures/hdfs/HdfsClientThreadLeakFilter.java @@ -35,6 +35,7 @@ public final class HdfsClientThreadLeakFilter implements ThreadFilter { || t.getName().startsWith("SSL Certificates Store Monitor") // hadoop 3 brings that in || t.getName().startsWith("GcTimeMonitor") // hadoop 3 || t.getName().startsWith("Command processor") // hadoop 3 - || t.getName().startsWith("ForkJoinPool-"); // hadoop 3 + || t.getName().startsWith("ForkJoinPool-") // hadoop 3 + || t.getName().startsWith("ForkJoinPool.commonPool-worker-"); // hadoop 3 } }