diff --git a/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateExecutor.java b/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateExecutor.java
index 3f17edebc4ce8..ebbf211e5ea5e 100644
--- a/flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateExecutor.java
+++ b/flink-state-backends/flink-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);