diff --git a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/block/DeletedBlockLogImpl.java b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/block/DeletedBlockLogImpl.java index 48ffadfe76df..c94036b9cbc5 100644 --- a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/block/DeletedBlockLogImpl.java +++ b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/block/DeletedBlockLogImpl.java @@ -478,11 +478,11 @@ public DatanodeDeletedBlockTransactions getTransactions( Set replicas = containerManager .getContainerReplicas( ContainerID.valueOf(txn.getContainerID())); - if (checkInadequateReplica(replicas, txn, dnList)) { + if (!checkInadequateReplica(replicas, txn, dnList)) { + getTransaction(txn, transactions, replicas, commandStatus, maxDeleteBlocksPerDatanode); + } else { metrics.incrSkippedTransaction(); - continue; } - getTransaction(txn, transactions, replicas, commandStatus, maxDeleteBlocksPerDatanode); } else if (txn.getCount() >= maxRetry || containerManager.getContainer(id).isOpen()) { metrics.incrSkippedTransaction(); }