lanyuanxiaoyao/hudi-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

perf(command): 增加启动同步任务的并发数

Browse Source
This commit is contained in:
v-zhangjc9
2024-05-21 19:03:59 +08:00
parent 9db8746496
commit e8eb7fab8a
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
service-command/src/main/java/com/lanyuanxiaoyao/service/command/commands/YarnCommand.java
View File

@@ -235,7 +235,7 @@ public class YarnCommand extends AbstractUtilShellComponent {
.distinct(); .distinct();
try (ProgressBar pb = CommandLineUtils.progressbarBuilder("Run jobs", ids.size()).build()) { try (ProgressBar pb = CommandLineUtils.progressbarBuilder("Run jobs", ids.size()).build()) {
ids ids
.asParallel(ExecutorProvider.EXECUTORS_2, 1) .asParallel(ExecutorProvider.EXECUTORS_5, 1)
.forEach(id -> { .forEach(id -> {
launcherService.syncStart(id); launcherService.syncStart(id);
pb.setExtraMessage(id.toString()); pb.setExtraMessage(id.toString());