This is an automated email from the ASF dual-hosted git repository.
aryangupta1998 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 377ca2fe7a7 HDDS-15787. Log OM block deletion ack at INFO in
SCMBlockProtocolServer (#10952)
377ca2fe7a7 is described below
commit 377ca2fe7a73807183012bb755409be532e11160
Author: rnblough <[email protected]>
AuthorDate: Wed Aug 5 03:03:22 2026 -0400
HDDS-15787. Log OM block deletion ack at INFO in SCMBlockProtocolServer
(#10952)
---
.../apache/hadoop/hdds/scm/server/SCMBlockProtocolServer.java | 9 +++------
1 file changed, 3 insertions(+), 6 deletions(-)
diff --git
a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/server/SCMBlockProtocolServer.java
b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/server/SCMBlockProtocolServer.java
index e563c9f08ff..4e3d3b7b3c1 100644
---
a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/server/SCMBlockProtocolServer.java
+++
b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/server/SCMBlockProtocolServer.java
@@ -268,10 +268,8 @@ public List<DeleteBlockGroupResult> deleteKeyBlocks(
for (BlockGroup bg : keyBlocksInfoList) {
totalBlocks += bg.getDeletedBlocks().size();
}
- if (LOG.isDebugEnabled()) {
- LOG.debug("SCM is informed by OM to delete {} keys. Total blocks to
deleted {}.",
+ LOG.info("SCM is informed by OM to delete {} keys. Total blocks to deleted
{}.",
keyBlocksInfoList.size(), totalBlocks);
- }
List<DeleteBlockGroupResult> results = new ArrayList<>();
Map<String, String> auditMap = Maps.newHashMap();
ScmBlockLocationProtocolProtos.DeleteScmBlockResult.Result resultCode;
@@ -283,9 +281,8 @@ public List<DeleteBlockGroupResult> deleteKeyBlocks(
perfMetrics.updateDeleteKeySuccessStats(keyBlocksInfoList.size(),
startNanos);
resultCode = ScmBlockLocationProtocolProtos.
DeleteScmBlockResult.Result.success;
- if (LOG.isDebugEnabled()) {
- LOG.debug("Total number of blocks ACK by SCM in this cycle: " +
totalBlocks);
- }
+ LOG.info("Total number of blocks ACK by SCM in this cycle: " +
totalBlocks);
+
} catch (IOException ioe) {
e = ioe;
perfMetrics.updateDeleteKeyFailedBlocks(totalBlocks);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
