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 512eb60..657d967 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
@@ -1,6 +1,5 @@
 package com.lanyuanxiaoyao.service.command.commands;
 
-import cn.hutool.core.thread.ThreadUtil;
 import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.StrUtil;
 import com.lanyuanxiaoyao.service.command.entity.TableMetaJob;
@@ -235,11 +234,13 @@ public class YarnCommand extends AbstractUtilShellComponent {
                                     .collect(TableMetaJob::getFlinkJobId)
                                     .distinct();
                             try (ProgressBar pb = CommandLineUtils.progressbarBuilder("Run jobs", ids.size()).build()) {
-                                ids.forEach(id -> {
-                                    launcherService.syncStart(id);
-                                    pb.setExtraMessage(id.toString());
-                                    pb.step();
-                                });
+                                ids
+                                        .asParallel(ExecutorProvider.EXECUTORS_2, 1)
+                                        .forEach(id -> {
+                                            launcherService.syncStart(id);
+                                            pb.setExtraMessage(id.toString());
+                                            pb.step();
+                                        });
                             }
                             return Constants.OPERATION_DONE;
                         } else {