From a5f1c82a25d28952854245a1ed8ccba3c50dcd50 Mon Sep 17 00:00:00 2001 From: Zakelly Date: Fri, 27 Sep 2024 15:04:17 +0800 Subject: [PATCH] [hotfix][state/forst] Use correct executor for ForSt coordinator --- .../java/org/apache/flink/state/forst/ForStStateExecutor.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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);