ソースを参照

pod 不存在

martin 2 年 前
コミット
9563cd5945

+ 1 - 1
simulation-resource-scheduler/src/main/java/com/css/simulation/resource/scheduler/service/ProjectService.java

@@ -384,7 +384,7 @@ public class ProjectService {
             for (int i = 0; i < parallelism; i++) {
                 String podName = projectUtil.getRandomPodName(projectId);   // 生成 podName
                 String tempReplace4 = podTemplateStringOfProject.replace("pod-name", podName); // pod 名称包括 projectId 和 随机字符串
-                String tempReplace5 = podTemplateStringOfProject.replace("namespace-name", kubernetesNamespace); // pod 名称包括 projectId 和 随机字符串
+                String tempReplace5 = tempReplace4.replace("namespace-name", kubernetesNamespace); // pod 名称包括 projectId 和 随机字符串
                 String tempPodString = tempReplace5.replace("node-name", nodeName);     // 指定 pod 运行节点
                 log.info("ProjectService--createPod 在节点 " + nodeName + " 开始执行 pod:" + tempPodString);
                 projectUtil.createPod(nodeName, podName, tempPodString);

+ 6 - 1
simulation-resource-scheduler/src/main/java/com/css/simulation/resource/scheduler/util/ProjectUtil.java

@@ -74,7 +74,12 @@ public class ProjectUtil {
         String key = "pod:" + podName + ":node";
         // 先删除 redis key
         RedisUtil.deleteByKey(stringRedisTemplate, "pod:" + podName + ":node");
-        KubernetesUtil.deletePod(apiClient, kubernetesNamespace, podName);
+        try {
+            KubernetesUtil.deletePod(apiClient, kubernetesNamespace, podName);
+        } catch (Exception e) {
+            log.info("ProjectUtil--deletePod pod " + podName + " 不存在。");
+        }
+
         log.info("ProjectUtil--deletePod 删除 pod 并删除 redis 键值对:" + key);
     }