STORM-2153: set disruptor reporter threads to daemon
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/8af4fcac Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/8af4fcac Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/8af4fcac Branch: refs/heads/1.x-branch Commit: 8af4fcac3267b8468c7a4cb02afbe9b7fd083d4b Parents: e13f903 Author: P. Taylor Goetz <[email protected]> Authored: Wed Jan 3 15:23:38 2018 -0500 Committer: P. Taylor Goetz <[email protected]> Committed: Wed Jan 3 15:23:38 2018 -0500 ---------------------------------------------------------------------- storm-core/src/jvm/org/apache/storm/utils/DisruptorQueue.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/8af4fcac/storm-core/src/jvm/org/apache/storm/utils/DisruptorQueue.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/org/apache/storm/utils/DisruptorQueue.java b/storm-core/src/jvm/org/apache/storm/utils/DisruptorQueue.java index 6ea3683..d7497d6 100644 --- a/storm-core/src/jvm/org/apache/storm/utils/DisruptorQueue.java +++ b/storm-core/src/jvm/org/apache/storm/utils/DisruptorQueue.java @@ -66,7 +66,8 @@ public class DisruptorQueue implements IStatefulObject { private static final Object INTERRUPT = new Object(); private static final String PREFIX = "disruptor-"; private static final FlusherPool FLUSHER = new FlusherPool(); - private static final ScheduledThreadPoolExecutor METRICS_REPORTER_EXECUTOR = new ScheduledThreadPoolExecutor(1); + private static final ScheduledThreadPoolExecutor METRICS_REPORTER_EXECUTOR = new ScheduledThreadPoolExecutor(1, + new ThreadFactoryBuilder().setDaemon(true).setNameFormat(PREFIX + "metrics-reporter").build()); private static int getNumFlusherPoolThreads() { int numThreads = 100;
