commit

simulation-resource-scheduler/src/main/java/com/css/simulation/resource/scheduler/app/service/ProjectApplicationService.java

@@ -823,7 +823,12 @@ public class ProjectApplicationService {
             Set<String> nodeOfPodKeySet = RedisUtil.getKeySetByPrefix(stringRedisTemplate, "project:" + projectId + ":pod:" + "project-" + projectId);
             Set<String> podNameSet = nodeOfPodKeySet.stream().map(key -> key.split(":")[3]).collect(Collectors.toSet());
             for (String podName : podNameSet) {
-                String nodeName = projectDomainService.getNodeNameOfPod(projectId, podName);
+                String nodeName;
+                try {
+                    nodeName = projectDomainService.getNodeNameOfPod(projectId, podName);
+                } catch (Exception e) {
+                    break;
+                }
                 // 删除 pod
                 projectDomainService.deletePod(podName);
                 // 节点并行度加一

simulation-resource-scheduler/src/main/java/com/css/simulation/resource/scheduler/domain/service/ProjectDomainService.java

@@ -260,6 +260,15 @@ public class ProjectDomainService {
         return s;
     }
 
+    public String getNodeNameOfPod2(String projectId, String podName) {
+        String key = "project:" + projectId + ":pod:" + podName + ":node";
+        final String s = stringRedisTemplate.opsForValue().get(key);
+        if (StringUtil.isEmpty(s)) {
+            throw new RuntimeException("无法获取 pod 运行所在节点：" + key);
+        }
+        return s;
+    }
+
 
     /**
      * 更改一个名字继续启动