From 57d620dbd4cb5dfec746cc16039d3843e64c181c Mon Sep 17 00:00:00 2001 From: Uma Maheswara Rao G Date: Fri, 29 Jul 2022 04:12:45 -0700 Subject: [PATCH] HDDS-7068: EC: Prematurely re-throwed the exception in reconstruction cleanup loop. (#3639) --- .../ec/reconstruction/ECReconstructionCoordinator.java | 2 +- .../ec/reconstruction/ECReconstructionCoordinatorTask.java | 4 ++++ 2 files changed, 5 insertions(+), 1 deletion(-) 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 b0f33e56a7f..0c79cbce045 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 @@ -179,8 +179,8 @@ public void reconstructECContainerGroup(long containerID, LOG.error("Exception while deleting the container {} at target: {}", containerID, dn, ioe); } - throw e; } + throw e; } } 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 38f3e320c68..e0aa14419a4 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 @@ -64,6 +64,10 @@ public void run() { // respective container. HDDS-6582 // 5. Close/finalize the recovered containers. long containerID = this.reconstructionCommandInfo.getContainerID(); + if (LOG.isDebugEnabled()) { + LOG.debug("Starting the EC reconstruction of the container {}", + containerID); + } try { SortedMap sourceNodeMap = reconstructionCommandInfo.getSources().stream().collect(Collectors