Ver Fonte

创建 pod 的传参问题

martin há 2 anos atrás
pai
commit
2b13ff863f

+ 2 - 3
simulation-resource-scheduler/src/main/java/com/css/simulation/resource/scheduler/manager/TaskManager.java

@@ -139,7 +139,7 @@ public class TaskManager {
                 } else {
                     projectMessageDTO.setTaskCompleted(taskCompleted + 1);
                     stringRedisTemplate.opsForValue().set(redisPrefix.getProjectRunningKey(), JsonUtil.beanToJson(projectMessageDTO));
-                    createNextPod(nodeName, projectId, podName);  // 项目没有完成则启动下一个 pod,同时删除上一个 pod
+                    createNextPod(projectId, nodeName, podName);  // 项目没有完成则启动下一个 pod,同时删除上一个 pod
                     return false;
                 }
             } catch (Exception exception) {
@@ -164,9 +164,8 @@ public class TaskManager {
         String lastPodString = FileUtil.read(podYamlDirectory + lastPodName + ".yaml");
         String nextPodName = projectUtil.getRandomPodName(projectId);
         String nextPodString = lastPodString.replace(lastPodName, nextPodName); // pod 名称包括 projectId 和 随机字符串
-        String nextPodFileName = nextPodName + ".yaml";     // 实际执行 pod 的文件名称
         log.info("TaskManager--createNextPod 创建项目 " + projectId + " 的下一个 pod。");
-        projectUtil.createPod(nodeName, nextPodFileName, nextPodString);
+        projectUtil.createPod(nodeName, nextPodName, nextPodString);
     }
 
     public void prepareScore(String projectRunningKey) {