瀏覽代碼

update DockerService

reghao 3 月之前
父節點
當前提交
096da02eae
共有 1 個文件被更改,包括 5 次插入1 次删除
  1. 5 1
      common/src/main/java/cn/reghao/bnt/common/docker/DockerService.java

+ 5 - 1
common/src/main/java/cn/reghao/bnt/common/docker/DockerService.java

@@ -74,9 +74,13 @@ public class DockerService {
         return docker.psAll().stream().map(inspectContainerResponse -> {
             String imageId = inspectContainerResponse.getImageId();
             Image image = imageMap.get(imageId);
+            if (image == null) {
+                log.error("container {}'s imageId {} not found" , inspectContainerResponse.getId(), imageId);
+                return null;
+            }
             String repoTag = image.getRepoTags().length > 0 ? image.getRepoTags()[0] : "<none>:<none>";
             return new DockerContainer(inspectContainerResponse, repoTag);
-        }).collect(Collectors.toList());
+        }).filter(Objects::nonNull).collect(Collectors.toList());
     }
 
     public void handleDockerContainer(String ops, String containerId) {