diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java index 5eef12b5716..f6c8c943479 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/namenode/FSNamesystem.java @@ -7475,9 +7475,10 @@ AddErasureCodingPolicyResponse[] addErasureCodingPolicies( ErasureCodingPolicy[] policies, final boolean logRetryCache) throws IOException { final String operationName = "addErasureCodingPolicies"; - String addECPolicyName = ""; + List addECPolicyNames = new ArrayList<>(policies.length); checkOperation(OperationCategory.WRITE); - List responses = new ArrayList<>(); + List responses = + new ArrayList<>(policies.length); boolean success = false; writeLock(); try { @@ -7488,7 +7489,7 @@ AddErasureCodingPolicyResponse[] addErasureCodingPolicies( ErasureCodingPolicy newPolicy = FSDirErasureCodingOp.addErasureCodingPolicy(this, policy, logRetryCache); - addECPolicyName = newPolicy.getName(); + addECPolicyNames.add(newPolicy.getName()); responses.add(new AddErasureCodingPolicyResponse(newPolicy)); } catch (HadoopIllegalArgumentException e) { responses.add(new AddErasureCodingPolicyResponse(policy, e)); @@ -7501,7 +7502,8 @@ AddErasureCodingPolicyResponse[] addErasureCodingPolicies( if (success) { getEditLog().logSync(); } - logAuditEvent(success, operationName, addECPolicyName, null, null); + logAuditEvent(success, operationName, addECPolicyNames.toString(), + null, null); } }