diff --git a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/ReplicationManager.java b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/ReplicationManager.java index 13f19f1fa9c9..df252065b3bb 100644 --- a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/ReplicationManager.java +++ b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/container/ReplicationManager.java @@ -606,7 +606,7 @@ private void deleteContainerReplicas(final ContainerInfo container, }); containerManager.updateContainerState(container.containerID(), HddsProtos.LifeCycleEvent.DELETE); - LOG.debug("Deleting empty container {} replicas,", container.containerID()); + LOG.debug("Deleting empty container replicas for {},", container); } /** @@ -621,8 +621,7 @@ private void handleContainerUnderDelete(final ContainerInfo container, if (replicas.size() == 0) { containerManager.updateContainerState(container.containerID(), HddsProtos.LifeCycleEvent.CLEANUP); - LOG.debug("Container {} state changes to DELETED", - container.containerID()); + LOG.debug("Container {} state changes to DELETED", container); } else { // Check whether to resend the delete replica command final List deletionInFlight = inflightDeletion @@ -638,8 +637,7 @@ private void handleContainerUnderDelete(final ContainerInfo container, filteredReplicas.stream().forEach(rp -> { sendDeleteCommand(container, rp.getDatanodeDetails(), false); }); - LOG.debug("Resend delete Container {} command", - container.containerID()); + LOG.debug("Resend delete Container command for {}", container); } } } @@ -692,8 +690,7 @@ private void forceCloseContainer(final ContainerInfo container, private void handleUnderReplicatedContainer(final ContainerInfo container, final ContainerReplicaCount replicaSet, final ContainerPlacementStatus placementStatus) { - LOG.debug("Handling under-replicated container: {}", - container.getContainerID()); + LOG.debug("Handling under-replicated container: {}", container); Set replicas = replicaSet.getReplica(); try {