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 14d34fb0af HDDS-8112. ECReconstructionCoordinator is not closed (#4365)
14d34fb0af is described below
commit 14d34fb0afac14fb24445449b2decd3a7fb6bf30
Author: Doroszlai, Attila <[email protected]>
AuthorDate: Thu Mar 9 11:07:14 2023 +0100
HDDS-8112. ECReconstructionCoordinator is not closed (#4365)
---
.../ozone/container/common/statemachine/DatanodeStateMachine.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git
a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/DatanodeStateMachine.java
b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/DatanodeStateMachine.java
index 01d114245a..5536b02e54 100644
---
a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/DatanodeStateMachine.java
+++
b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/statemachine/DatanodeStateMachine.java
@@ -94,6 +94,7 @@ public class DatanodeStateMachine implements Closeable {
private final ExecutorService executorService;
private final ConfigurationSource conf;
private final SCMConnectionManager connectionManager;
+ private final ECReconstructionCoordinator ecReconstructionCoordinator;
private StateContext context;
private final OzoneContainer container;
private final DatanodeCRLStore dnCRLStore;
@@ -202,9 +203,8 @@ public class DatanodeStateMachine implements Closeable {
ecReconstructionMetrics = ECReconstructionMetrics.create();
- ECReconstructionCoordinator ecReconstructionCoordinator =
- new ECReconstructionCoordinator(conf, certClient, context,
- ecReconstructionMetrics);
+ ecReconstructionCoordinator = new ECReconstructionCoordinator(
+ conf, certClient, context, ecReconstructionMetrics);
// This is created as an instance variable as Mockito needs to access it in
// a test. The test mocks it in a running mini-cluster.
@@ -390,6 +390,7 @@ public class DatanodeStateMachine implements Closeable {
*/
@Override
public void close() throws IOException {
+ IOUtils.close(LOG, ecReconstructionCoordinator);
if (stateMachineThread != null) {
stateMachineThread.interrupt();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
