This is an automated email from the ASF dual-hosted git repository.
nanda 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 7d31d9e522 HDDS-12410. Add detailed block info for ALLOCATE_BLOCK
audit log (#7965)
7d31d9e522 is described below
commit 7d31d9e52256c57bddd7e862671b9113d6d37b19
Author: Symious <[email protected]>
AuthorDate: Tue Mar 4 16:16:20 2025 +0800
HDDS-12410. Add detailed block info for ALLOCATE_BLOCK audit log (#7965)
---
.../org/apache/hadoop/hdds/scm/server/SCMBlockProtocolServer.java | 5 +++++
1 file changed, 5 insertions(+)
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 0c3627e503..e81569dd2a 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
@@ -42,6 +42,7 @@
import java.util.Map;
import java.util.Objects;
import java.util.concurrent.TimeoutException;
+import java.util.stream.Collectors;
import org.apache.commons.lang3.StringUtils;
import org.apache.hadoop.fs.CommonConfigurationKeys;
import org.apache.hadoop.hdds.client.BlockID;
@@ -224,6 +225,10 @@ public List<AllocatedBlock> allocateBlock(
}
auditMap.put("allocated", String.valueOf(blocks.size()));
+ String blockIDs = blocks.stream().limit(10)
+ .map(block -> block.getBlockID().toString())
+ .collect(Collectors.joining(", ", "[", "]"));
+ auditMap.put("sampleBlocks", blockIDs);
if (blocks.size() < num) {
AUDIT.logWriteFailure(buildAuditMessageForFailure(
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
