You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ag...@apache.org on 2020/06/25 14:17:02 UTC
[storm] branch master updated: MINOR: Adding Supervisor StormTimer
thread names
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 <kp...@verizonmedia.com>
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();
}