commit | c92b7a56017e4fd9a87209b072e836399f3c8ace | [log] [tgz] |
---|---|---|
author | Boris S <bshkolnik@linkedin.com> | Fri Aug 07 08:56:51 2020 -0700 |
committer | Boris S <bshkolnik@linkedin.com> | Fri Aug 07 08:56:51 2020 -0700 |
tree | 4d143c1027b83fb862ef06fc3f1dda7258f11036 | |
parent | 2b148c924532dd6ee10acc3b169e5ccbf5953618 [diff] |
make MonitorPartition thread a daemon
diff --git a/samza-core/src/main/java/org/apache/samza/coordinator/StreamPartitionCountMonitor.java b/samza-core/src/main/java/org/apache/samza/coordinator/StreamPartitionCountMonitor.java index 7d76c8c..ee4490f 100644 --- a/samza-core/src/main/java/org/apache/samza/coordinator/StreamPartitionCountMonitor.java +++ b/samza-core/src/main/java/org/apache/samza/coordinator/StreamPartitionCountMonitor.java
@@ -238,7 +238,9 @@ private static final AtomicInteger INSTANCE_NUM = new AtomicInteger(); public Thread newThread(Runnable runnable) { - return new Thread(runnable, PREFIX + INSTANCE_NUM.getAndIncrement()); + Thread thread = new Thread(runnable, PREFIX + INSTANCE_NUM.getAndIncrement()); + thread.setDaemon(true); + return thread; } } }