diff --git a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/ec/reconstruction/ECReconstructionCoordinator.java b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/ec/reconstruction/ECReconstructionCoordinator.java index a7e5bfb92d72..6bd0a4de9653 100644 --- a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/ec/reconstruction/ECReconstructionCoordinator.java +++ b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/ec/reconstruction/ECReconstructionCoordinator.java @@ -154,7 +154,9 @@ public void reconstructECContainerGroup(long containerID, for (Map.Entry indexDnPair : targetNodeMap .entrySet()) { DatanodeDetails dn = indexDnPair.getValue(); - Integer index = indexDnPair.getKey(); + int index = indexDnPair.getKey(); + LOG.debug("Creating container {} on datanode {} for index {}", + containerID, dn, index); containerOperationClient .createRecoveringContainer(containerID, dn, repConfig, containerToken, index); @@ -172,6 +174,7 @@ public void reconstructECContainerGroup(long containerID, // 3. Close containers for (DatanodeDetails dn: recoveringContainersCreatedDNs) { + LOG.debug("Closing container {} on datanode {}", containerID, dn); containerOperationClient .closeContainer(containerID, dn, repConfig, containerToken); } diff --git a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/ec/reconstruction/ECReconstructionCoordinatorTask.java b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/ec/reconstruction/ECReconstructionCoordinatorTask.java index c24e06058096..6d32f3a3f3ea 100644 --- a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/ec/reconstruction/ECReconstructionCoordinatorTask.java +++ b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/ec/reconstruction/ECReconstructionCoordinatorTask.java @@ -60,12 +60,10 @@ public void runTask() { // 4. Write the recovered chunks to given targets/write locally to // respective container. HDDS-6582 // 5. Close/finalize the recovered containers. - long containerID = this.reconstructionCommandInfo.getContainerID(); long start = Time.monotonicNow(); - if (LOG.isDebugEnabled()) { - LOG.debug("Starting the EC reconstruction of the container {}", - containerID); - } + + LOG.info("{}", this); + try { reconstructionCoordinator.reconstructECContainerGroup( reconstructionCommandInfo.getContainerID(), @@ -73,12 +71,12 @@ public void runTask() { reconstructionCommandInfo.getSourceNodeMap(), reconstructionCommandInfo.getTargetNodeMap()); long elapsed = Time.monotonicNow() - start; - LOG.info("Completed {} in {} ms", reconstructionCommandInfo, elapsed); setStatus(Status.DONE); + LOG.info("{} in {} ms", this, elapsed); } catch (Exception e) { long elapsed = Time.monotonicNow() - start; - LOG.warn("Failed {} after {} ms", reconstructionCommandInfo, elapsed, e); setStatus(Status.FAILED); + LOG.warn("{} after {} ms", this, elapsed, e); } }