This is an automated email from the ASF dual-hosted git repository.

adoroszlai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git


The following commit(s) were added to refs/heads/master by this push:
     new 73072cf1dab HDDS-14832. Improve Datanode dispatcher unexpected 
container state message (#9918)
73072cf1dab is described below

commit 73072cf1dab50923a6173cf5c735c8637c7a1171
Author: Ming Wei <[email protected]>
AuthorDate: Sat Mar 14 14:42:01 2026 +0800

    HDDS-14832. Improve Datanode dispatcher unexpected container state message 
(#9918)
---
 .../apache/hadoop/ozone/container/common/impl/HddsDispatcher.java   | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/impl/HddsDispatcher.java
 
b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/impl/HddsDispatcher.java
index 12fed16b364..b298c00bcd9 100644
--- 
a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/impl/HddsDispatcher.java
+++ 
b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/impl/HddsDispatcher.java
@@ -399,12 +399,14 @@ && getMissingContainerSet().contains(containerID)) {
                   .getMessage());
         }
         // For container to be moved to unhealthy state here, the container can
-        // only be in open or closing state.
+        // only be in open, closing, or recovering state.
         State containerState = container.getContainerData().getState();
         Preconditions.checkState(
             containerState == State.OPEN
                 || containerState == State.CLOSING
-                || containerState == State.RECOVERING);
+                || containerState == State.RECOVERING,
+            "Expected container %s to be in OPEN/CLOSING/RECOVERING state but 
was %s",
+            containerID, containerState);
         // mark and persist the container state to be unhealthy
         try {
           ContainerScanError error = new 
ContainerScanError(ContainerScanError.FailureType.WRITE_FAILURE,


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to