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/03 20:24:26 UTC
storm git commit: STORM-2153: set disruptor reporter threads to daemon
Repository: storm
Updated Branches:
refs/heads/metrics_v2 e13f90345 -> 8af4fcac3
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/metrics_v2
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;