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 14ee03be39c0a7..067b155ae83e9f 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
@@ -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);