From e8eb7fab8a10197264aeb2cd56bcd0dd94b22111 Mon Sep 17 00:00:00 2001 From: v-zhangjc9 Date: Tue, 21 May 2024 19:03:59 +0800 Subject: [PATCH] =?UTF-8?q?perf(command):=20=E5=A2=9E=E5=8A=A0=E5=90=AF?= =?UTF-8?q?=E5=8A=A8=E5=90=8C=E6=AD=A5=E4=BB=BB=E5=8A=A1=E7=9A=84=E5=B9=B6?= =?UTF-8?q?=E5=8F=91=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../lanyuanxiaoyao/service/command/commands/YarnCommand.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/service-command/src/main/java/com/lanyuanxiaoyao/service/command/commands/YarnCommand.java b/service-command/src/main/java/com/lanyuanxiaoyao/service/command/commands/YarnCommand.java index 657d967..fdb8f2f 100644 --- a/service-command/src/main/java/com/lanyuanxiaoyao/service/command/commands/YarnCommand.java +++ b/service-command/src/main/java/com/lanyuanxiaoyao/service/command/commands/YarnCommand.java @@ -235,7 +235,7 @@ public class YarnCommand extends AbstractUtilShellComponent { .distinct(); try (ProgressBar pb = CommandLineUtils.progressbarBuilder("Run jobs", ids.size()).build()) { ids - .asParallel(ExecutorProvider.EXECUTORS_2, 1) + .asParallel(ExecutorProvider.EXECUTORS_5, 1) .forEach(id -> { launcherService.syncStart(id); pb.setExtraMessage(id.toString());