SAMZA-2795: Set thread to daemon thread for operator executor service

mynameborat · Nov 8, 2023 · 0e137de · 0e137de
1 parent 24e530d
commit 0e137de
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/samza-core/src/main/java/org/apache/samza/task/DefaultTaskExecutorFactory.java b/samza-core/src/main/java/org/apache/samza/task/DefaultTaskExecutorFactory.java
@@ -68,7 +68,9 @@ public ExecutorService getOperatorExecutor(TaskName taskName, Config config) {
       } else {
         LOG.info("Using single threaded thread pool as operator thread pool for task {}", key.getTaskName());
         operatorExecutor = Executors.newSingleThreadExecutor(
-            new ThreadFactoryBuilder().setNameFormat("Samza " + key.getTaskName() + " Thread-%d").build());
+            new ThreadFactoryBuilder().setNameFormat("Samza " + key.getTaskName() + " Thread-%d")
+                .setDaemon(true)
+                .build());
       }
 
       return operatorExecutor;