commit e832204321b07f9a13c48ec75f54627b153d97f1
author agresch <agresch@gmail.com> Thu Jun 25 09:16:45 2020 -0500
committer GitHub <noreply@github.com> Thu Jun 25 09:16:45 2020 -0500
tree 656ba253309cc6104020a14f8381137935c9c1d1
parent a59d82f8342ff00af041fb6f283c172f0b2f07b3
parent 17db8a9799805d77e8a7cbaf6cfe6d4ec1ce2822

Merge pull request #3290 from kishorvpatil/add-supervisor-t-names

MINOR: Adding Supervisor StormTimer thread names

storm-server/src/main/java/org/apache/storm/daemon/supervisor/Supervisor.java

diff --git a/storm-server/src/main/java/org/apache/storm/daemon/supervisor/Supervisor.java b/storm-server/src/main/java/org/apache/storm/daemon/supervisor/Supervisor.java
index ce597de..c72b4cb 100644
--- a/storm-server/src/main/java/org/apache/storm/daemon/supervisor/Supervisor.java
+++ b/storm-server/src/main/java/org/apache/storm/daemon/supervisor/Supervisor.java
@@ -181,11 +181,11 @@
             throw Utils.wrapInRuntime(e);
         }
 
-        this.heartbeatTimer = new StormTimer(null, new DefaultUncaughtExceptionHandler());
+        this.heartbeatTimer = new StormTimer("HBTimer", new DefaultUncaughtExceptionHandler());
 
-        this.workerHeartbeatTimer = new StormTimer(null, new DefaultUncaughtExceptionHandler());
+        this.workerHeartbeatTimer = new StormTimer("WorkerHBTimer", new DefaultUncaughtExceptionHandler());
 
-        this.eventTimer = new StormTimer(null, new DefaultUncaughtExceptionHandler());
+        this.eventTimer = new StormTimer("EventTimer", new DefaultUncaughtExceptionHandler());
         
         this.supervisorThriftInterface = createSupervisorIface();
     }