[samza] branch master updated: make MonitorPartition thread a daemon

[bo...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

boryas pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git


The following commit(s) were added to refs/heads/master by this push:
     new c92b7a5  make MonitorPartition thread a daemon
     new c8bf03d  Merge pull request #1410 from sborya/master
c92b7a5 is described below

commit c92b7a56017e4fd9a87209b072e836399f3c8ace
Author: Boris S <bs...@linkedin.com>
AuthorDate: Fri Aug 7 08:56:51 2020 -0700

    make MonitorPartition thread a daemon
---
 .../org/apache/samza/coordinator/StreamPartitionCountMonitor.java     | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

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 @@ public class StreamPartitionCountMonitor {
     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;
     }
   }
 }