From d9cfbc85fd57b542f56aab0fa7befdcc63463509 Mon Sep 17 00:00:00 2001 From: peterxcli Date: Sat, 26 Apr 2025 10:03:16 +0000 Subject: [PATCH] HDDS-12902. ecReconstructReadExecutor should be created as as a daemon --- .../commandhandler/CloseContainerCommandHandler.java | 5 +++++ .../ec/reconstruction/ECReconstructionCoordinator.java | 1 + 2 files changed, 6 insertions(+) diff --git a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/CloseContainerCommandHandler.java b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/CloseContainerCommandHandler.java index 1a1594cf8a99..364cbd9d1934 100644 --- a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/CloseContainerCommandHandler.java +++ b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/commandhandler/CloseContainerCommandHandler.java @@ -227,4 +227,9 @@ public int getThreadPoolMaxPoolSize() { public int getThreadPoolActivePoolSize() { return executor.getActiveCount(); } + + @Override + public void stop() { + executor.shutdownNow(); + } } 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 4694850b936c..d5a18775564b 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 @@ -464,6 +464,7 @@ public void close() throws IOException { if (ecReconstructWriteExecutor.isInitialized()) { ecReconstructWriteExecutor.get().shutdownNow(); } + ecReconstructReadExecutor.shutdownNow(); } private Pipeline rebuildInputPipeline(ECReplicationConfig repConfig,