This is an automated email from the ASF dual-hosted git repository.
ljain 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 2c561d0 HDDS-6283. Change ContainerStateMachine ContainerOpExecutor
name (#3055)
2c561d0 is described below
commit 2c561d0937de74c0cf66ec79950c9a796ab139da
Author: hao guo <[email protected]>
AuthorDate: Thu Feb 17 15:38:27 2022 +0800
HDDS-6283. Change ContainerStateMachine ContainerOpExecutor name (#3055)
---
.../common/transport/server/ratis/ContainerStateMachine.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
diff --git
a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/ContainerStateMachine.java
b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/ContainerStateMachine.java
index 4ef5320..494cfe1 100644
---
a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/ContainerStateMachine.java
+++
b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/ContainerStateMachine.java
@@ -38,6 +38,7 @@ import java.util.concurrent.atomic.AtomicBoolean;
import java.util.function.Consumer;
import java.util.stream.Collectors;
+import com.google.common.util.concurrent.ThreadFactoryBuilder;
import org.apache.hadoop.hdds.HddsUtils;
import org.apache.hadoop.hdds.conf.ConfigurationSource;
import org.apache.hadoop.hdds.conf.DatanodeRatisServerConfig;
@@ -197,7 +198,11 @@ public class ContainerStateMachine extends
BaseStateMachine {
applyTransactionSemaphore = new Semaphore(maxPendingApplyTransactions);
stateMachineHealthy = new AtomicBoolean(true);
- this.executor = Executors.newFixedThreadPool(numContainerOpExecutors);
+ this.executor = Executors.newFixedThreadPool(numContainerOpExecutors,
+ new ThreadFactoryBuilder()
+ .setNameFormat("ContainerOp-" + gid.getUuid() + "-%d")
+ .build());
+
this.containerTaskQueues = new ConcurrentHashMap<>();
this.waitOnBothFollowers = conf.getObject(
DatanodeConfiguration.class).waitOnAllFollowers();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
