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());