[dingo-exec] change new threadPool each time to CacheThreadPool

dingodb · Mar 4, 2022 · 2b92378 · 2b92378
1 parent 681789d
commit 2b92378
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/dingo-exec/src/main/java/io/dingodb/exec/impl/TaskImpl.java b/dingo-exec/src/main/java/io/dingodb/exec/impl/TaskImpl.java
@@ -61,6 +61,8 @@ public final class TaskImpl implements Task {
     @Getter
     private final List<Id> runList;
 
+    private static ExecutorService executorService = Executors.newCachedThreadPool();
+
     @JsonCreator
     public TaskImpl(
         @JsonProperty("jobId") String jobId,
@@ -102,7 +104,6 @@ public void deleteOperator(@Nonnull Operator operator) {
 
     public void run() {
         log.info("Task is starting at {}...", location);
-        ExecutorService executorService = Executors.newFixedThreadPool(runList.size());
         runList.forEach(id -> {
             final Operator operator = operators.get(id);
             assert operator instanceof SourceOperator