lyhzzz преди 1 година
родител
ревизия
ebf74c4e38
променени са 1 файла, в които са добавени 1 реда и са изтрити 1 реда
  1. 1 1
      src/main/java/com/fdkankan/mqcontroller/task/TaskService.java

+ 1 - 1
src/main/java/com/fdkankan/mqcontroller/task/TaskService.java

@@ -283,7 +283,7 @@ public class TaskService {
                 if(!mqEcsList.isEmpty()){
                     log.info("openEcsList--有启动中的ecs,等待启动完毕执行。。。");
                     openList.offer(take);
-                    continue;
+                    return;
                 }
                 Boolean flag = createEcs( take.getMqScalingConfig());
                 if(flag){