This is an automated email from the ASF dual-hosted git repository.
sammichen 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 f3b482a HDDS-5922. ignore deletetransaction when container is not
found (#2793)
f3b482a is described below
commit f3b482af10364731796c3545d0ebed1997e0e850
Author: Jackson Yao <[email protected]>
AuthorDate: Wed Nov 10 15:42:59 2021 +0800
HDDS-5922. ignore deletetransaction when container is not found (#2793)
---
.../apache/hadoop/hdds/scm/container/ContainerStateManagerImpl.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git
a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/ContainerStateManagerImpl.java
b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/ContainerStateManagerImpl.java
index b8577fd..25c962c 100644
---
a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/ContainerStateManagerImpl.java
+++
b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/ContainerStateManagerImpl.java
@@ -415,6 +415,11 @@ public final class ContainerStateManagerImpl
deleteTransactionMap.entrySet()) {
final ContainerInfo info = containers.getContainerInfo(
transaction.getKey());
+ if (info == null) {
+ LOG.warn("Cannot find container {}, transaction id is {}",
+ transaction.getKey(), transaction.getValue());
+ continue;
+ }
info.updateDeleteTransactionId(transaction.getValue());
transactionBuffer.addToBuffer(containerStore, info.containerID(),
info);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
