This is an automated email from the ASF dual-hosted git repository.

agresch pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/storm.git


The following commit(s) were added to refs/heads/master by this push:
     new 17db8a9  MINOR: Adding Supervisor StormTimer thread names
     new e832204  Merge pull request #3290 from 
kishorvpatil/add-supervisor-t-names
17db8a9 is described below

commit 17db8a9799805d77e8a7cbaf6cfe6d4ec1ce2822
Author: Kishor Patil <[email protected]>
AuthorDate: Tue Jun 23 00:57:35 2020 -0400

    MINOR: Adding Supervisor StormTimer thread names
---
 .../main/java/org/apache/storm/daemon/supervisor/Supervisor.java    | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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 @@ public class Supervisor implements DaemonCommon, 
AutoCloseable {
             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();
     }

Reply via email to