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 4c42bff28c55..4ee10b70b3a8 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; @@ -226,6 +227,10 @@ public List 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(