You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2018/01/22 17:41:31 UTC
[25/38] storm git commit: STORM-2153: set disruptor reporter threads
to daemon
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 <pt...@gmail.com>
Authored: Wed Jan 3 15:23:38 2018 -0500
Committer: P. Taylor Goetz <pt...@gmail.com>
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;