This is an automated email from the ASF dual-hosted git repository.
adoroszlai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new cf1fb88740 HDDS-12902. Shutdown executor in
CloseContainerCommandHandler and ECReconstructionCoordinator (#8341)
cf1fb88740 is described below
commit cf1fb88740c4465f17070d9a61039d5c5a169683
Author: Peter Lee <[email protected]>
AuthorDate: Sun Apr 27 13:30:26 2025 +0800
HDDS-12902. Shutdown executor in CloseContainerCommandHandler and
ECReconstructionCoordinator (#8341)
---
.../statemachine/commandhandler/CloseContainerCommandHandler.java | 5 +++++
.../container/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 1a1594cf8a..364cbd9d19 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 d8856f081d..af5c9c5892 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,
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
