[hotfix][state/forst] Use correct executor for ForSt coordinator

Zakelly · Sep 27, 2024 · a5f1c82 · a5f1c82
1 parent 4bed35b
commit a5f1c82
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateExecutor.java b/...ink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateExecutor.java
@@ -82,7 +82,7 @@ public ForStStateExecutor(
         if (isWriteInline) {
             Preconditions.checkState(readIoParallelism > 0);
             this.coordinatorThread =
-                    Executors.newSingleThreadScheduledExecutor(
+                    Executors.newSingleThreadExecutor(
                             new ExecutorThreadFactory("ForSt-StateExecutor-Coordinator-And-Write"));
             this.readThreadCount = readIoParallelism;
             this.readThreads =
@@ -95,7 +95,7 @@ public ForStStateExecutor(
         } else {
             Preconditions.checkState(readIoParallelism > 0 || writeIoParallelism > 0);
             this.coordinatorThread =
-                    Executors.newSingleThreadScheduledExecutor(
+                    Executors.newSingleThreadExecutor(
                             new ExecutorThreadFactory("ForSt-StateExecutor-Coordinator"));
             if (readIoParallelism <= 0 || writeIoParallelism <= 0) {
                 this.readThreadCount = Math.max(readIoParallelism, writeIoParallelism);