[flink] 01/04: [FLINK-18035][runtime] Use fixed thread pool

[chesnay]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 87afb9e08b7a3fb846eaa406a139646096450f50
Author: Chesnay Schepler <ches...@apache.org>
AuthorDate: Fri May 29 14:11:47 2020 +0200

    [FLINK-18035][runtime] Use fixed thread pool
---
 .../java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java
index 9772700..82d2451 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java
@@ -30,7 +30,6 @@ import org.apache.flink.metrics.MetricGroup;
 import org.apache.flink.runtime.akka.AkkaUtils;
 import org.apache.flink.runtime.blob.BlobCacheService;
 import org.apache.flink.runtime.clusterframework.types.ResourceID;
-import org.apache.flink.runtime.concurrent.Executors;
 import org.apache.flink.runtime.concurrent.FutureUtils;
 import org.apache.flink.runtime.concurrent.ScheduledExecutor;
 import org.apache.flink.runtime.entrypoint.FlinkParseException;
@@ -74,6 +73,7 @@ import java.util.ArrayList;
 import java.util.Collection;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
 import java.util.concurrent.TimeUnit;
 
 import static org.apache.flink.util.Preconditions.checkNotNull;
@@ -367,7 +367,7 @@ public class TaskManagerRunner implements 
FatalErrorHandler, AutoCloseableAsync
                        resourceID,
                        
taskManagerServicesConfiguration.getSystemResourceMetricsProbingInterval());
 
-               final ExecutorService ioExecutor = 
Executors.newCachedThreadPool(
+               final ExecutorService ioExecutor = Executors.newFixedThreadPool(
                        taskManagerServicesConfiguration.getNumIoThreads(),
                        new ExecutorThreadFactory("flink-taskexecutor-io"));