| commit | c8bf03d8804df45310783aa28919c20b54d0ca65 | [log] [tgz] |
|---|---|---|
| author | Boris Shkolnik <boryas@apache.org> | Fri Aug 07 11:18:42 2020 -0700 |
| committer | GitHub <noreply@github.com> | Fri Aug 07 11:18:42 2020 -0700 |
| tree | 4d143c1027b83fb862ef06fc3f1dda7258f11036 | |
| parent | 2b148c924532dd6ee10acc3b169e5ccbf5953618 [diff] | |
| parent | c92b7a56017e4fd9a87209b072e836399f3c8ace [diff] |
Merge pull request #1410 from sborya/master 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; } } }