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

Zakelly · Sep 29, 2024 · 3f2fd23 · 3f2fd23
1 parent 1ba3d39
commit 3f2fd23
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
@@ -85,7 +85,7 @@ public ForStStateExecutor(
             this.coordinatorThread =
                     coordinatorInline
                             ? org.apache.flink.util.concurrent.Executors.newDirectExecutorService()
-                            : Executors.newSingleThreadScheduledExecutor(
+                            : Executors.newSingleThreadExecutor(
                                     new ExecutorThreadFactory(
                                             "ForSt-StateExecutor-Coordinator-And-Write"));
             this.readThreadCount = readIoParallelism;
@@ -101,7 +101,7 @@ public ForStStateExecutor(
             this.coordinatorThread =
                     coordinatorInline
                             ? org.apache.flink.util.concurrent.Executors.newDirectExecutorService()
-                            : Executors.newSingleThreadScheduledExecutor(
+                            : Executors.newSingleThreadExecutor(
                                     new ExecutorThreadFactory("ForSt-StateExecutor-Coordinator"));
             if (readIoParallelism <= 0 || writeIoParallelism <= 0) {
                 this.readThreadCount = Math.max(readIoParallelism, writeIoParallelism);