Dump hot threads

Signed-off-by: Craig Perkins <[email protected]>
cwperks · Dec 5, 2024 · bb04376 · bb04376
1 parent 7d4225e
commit bb04376
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/src/integrationTest/java/org/opensearch/test/framework/cluster/LocalOpenSearchCluster.java b/src/integrationTest/java/org/opensearch/test/framework/cluster/LocalOpenSearchCluster.java
@@ -55,6 +55,7 @@
 import org.apache.logging.log4j.Logger;
 
 import org.opensearch.action.admin.cluster.health.ClusterHealthResponse;
+import org.opensearch.action.admin.cluster.node.hotthreads.NodesHotThreadsResponse;
 import org.opensearch.action.admin.cluster.node.stats.NodeStats;
 import org.opensearch.action.admin.cluster.node.stats.NodesStatsRequest;
 import org.opensearch.action.admin.cluster.node.stats.NodesStatsResponse;
@@ -254,6 +255,13 @@ public void stop(boolean checkActiveThreads) throws IOException {
                             }
                         }
                         if (threadsActive) {
+                            // TODO Hot Threads added for debugging
+                            NodesHotThreadsResponse hotThreadsResponse = adminClient.cluster().prepareNodesHotThreads().get();
+                            if (hotThreadsResponse.getNodes().isEmpty()) {
+                                log.warn("Hot threads response is empty");
+                                break;
+                            }
+                            log.warn("Hot threads stack trace: {}", hotThreadsResponse.getNodes().get(0).getHotThreads());
                             break;
                         }
                     }