Make flush threads daemon to allow jvm to exit if these threads are a…

…ctive
snowflakedb · Jun 25, 2024 · 6293c2c · 6293c2c
1 parent d2e7bb3
commit 6293c2c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/net/snowflake/ingest/streaming/internal/FlushService.java b/src/main/java/net/snowflake/ingest/streaming/internal/FlushService.java
@@ -279,7 +279,7 @@ CompletableFuture<Void> flush(boolean isForce) {
   private void createWorkers() {
     // Create thread for checking and scheduling flush job
     ThreadFactory flushThreadFactory =
-        new ThreadFactoryBuilder().setNameFormat("ingest-flush-thread").build();
+        new ThreadFactoryBuilder().setNameFormat("ingest-flush-thread").setDaemon(true).build();
     this.flushWorker = Executors.newSingleThreadScheduledExecutor(flushThreadFactory);
     this.flushWorker.scheduleWithFixedDelay(
         () -> {