MINOR: Adding Supervisor StormTimer thread names
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();
}