diff --git a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/ozoneimpl/ContainerController.java b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/ozoneimpl/ContainerController.java index 9beec5b16c86..171303dc0b4d 100644 --- a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/ozoneimpl/ContainerController.java +++ b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/ozoneimpl/ContainerController.java @@ -112,7 +112,12 @@ public void markContainerForClose(final long containerId) public void markContainerUnhealthy(final long containerId) throws IOException { Container container = containerSet.getContainer(containerId); - getHandler(container).markContainerUnhealthy(container); + if (container != null) { + getHandler(container).markContainerUnhealthy(container); + } else { + LOG.warn("Container {} not found, may be deleted, skip mark UNHEALTHY", + containerId); + } } /** @@ -206,7 +211,12 @@ public Iterator> getContainers(HddsVolume volume) { void updateDataScanTimestamp(long containerId, Instant timestamp) throws IOException { Container container = containerSet.getContainer(containerId); - container.updateDataScanTimestamp(timestamp); + if (container != null) { + container.updateDataScanTimestamp(timestamp); + } else { + LOG.warn("Container {} not found, may be deleted, " + + "skip update DataScanTimestamp", containerId); + } } }