Github user arunmahadevan commented on a diff in the pull request:
https://github.com/apache/storm/pull/2482#discussion_r158759325
--- Diff:
storm-client/src/jvm/org/apache/storm/metric/FileBasedEventLogger.java ---
@@ -59,8 +62,12 @@ private void initLogWriter(Path logFilePath) {
private void setUpFlushTask() {
- ScheduledExecutorService scheduler =
Executors.newSingleThreadScheduledExecutor();
- Runnable task = new Runnable() {
+ ThreadFactory threadFactory = new ThreadFactoryBuilder()
+ .setNameFormat("event-logger-flush-%d")
--- End diff --
should we add `setDaemon(true)` ?
---