You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by yo...@apache.org on 2023/01/17 11:55:37 UTC
[iotdb] branch Fix-configuration-error updated (5e2e9d33c7 -> 71824140f6)
This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a change to branch Fix-configuration-error
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 5e2e9d33c7 Fix typo in README
new b1ed94f3ed stash
new 3c1cd0cca0 configuration output
new 3dac9cb5d0 stash
new 71824140f6 Update ClientPoolFactory.java
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../iotdb/confignode/conf/ConfigNodeConfig.java | 27 ++++++++++++++
.../iotdb/confignode/service/ConfigNode.java | 5 +++
.../thrift/ConfigNodeRPCServiceProcessor.java | 10 ++++++
.../iotdb/commons/client/ClientPoolFactory.java | 17 ++++++---
.../apache/iotdb/commons/conf/CommonConfig.java | 42 ++++++++++++++++++++--
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 11 ++++--
.../java/org/apache/iotdb/db/service/DataNode.java | 5 +++
.../iotdb/tsfile/common/conf/TSFileConfig.java | 27 ++++++++++++++
8 files changed, 133 insertions(+), 11 deletions(-)
[iotdb] 02/04: configuration output
Posted by yo...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a commit to branch Fix-configuration-error
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 3c1cd0cca0de56c7def8fc1197c29361f9268dc2
Author: YongzaoDan <53...@qq.com>
AuthorDate: Tue Jan 17 17:49:44 2023 +0800
configuration output
---
.../iotdb/confignode/conf/ConfigNodeConfig.java | 27 ++++++++++++++++++++++
.../iotdb/confignode/service/ConfigNode.java | 5 ++++
.../thrift/ConfigNodeRPCServiceProcessor.java | 10 ++++++++
.../apache/iotdb/commons/conf/CommonConfig.java | 27 ++++++++++++++++++++++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 11 ++++++---
.../java/org/apache/iotdb/db/service/DataNode.java | 5 ++++
.../iotdb/tsfile/common/conf/TSFileConfig.java | 27 ++++++++++++++++++++++
7 files changed, 109 insertions(+), 3 deletions(-)
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfig.java b/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfig.java
index 2cb6e8318a..50e9c3ae2a 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfig.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeConfig.java
@@ -26,6 +26,8 @@ import org.apache.iotdb.confignode.manager.load.balancer.router.priority.IPriori
import org.apache.iotdb.rpc.RpcUtils;
import java.io.File;
+import java.lang.reflect.Field;
+import java.util.Arrays;
import java.util.concurrent.TimeUnit;
public class ConfigNodeConfig {
@@ -269,4 +271,29 @@ public class ConfigNodeConfig {
public void setCqMinEveryIntervalInMs(long cqMinEveryIntervalInMs) {
this.cqMinEveryIntervalInMs = cqMinEveryIntervalInMs;
}
+
+ public String getConfigMessage() {
+ StringBuilder configMessage = new StringBuilder();
+ String configContent;
+ for (Field configField : ConfigNodeConfig.class.getDeclaredFields()) {
+ try {
+ String configType = configField.getGenericType().getTypeName();
+ if (configType.contains("java.lang.String[]")) {
+ String[] configList = (String[]) configField.get(this);
+ configContent = Arrays.asList(configList).toString();
+ } else {
+ configContent = configField.get(this).toString();
+ }
+ configMessage
+ .append("\n\t")
+ .append(configField.getName())
+ .append("=")
+ .append(configContent)
+ .append(";");
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+ return configMessage.toString();
+ }
}
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/service/ConfigNode.java b/confignode/src/main/java/org/apache/iotdb/confignode/service/ConfigNode.java
index 8638c24a1a..74be641767 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/service/ConfigNode.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/service/ConfigNode.java
@@ -110,6 +110,9 @@ public class ConfigNode implements ConfigNodeMBean {
configManager.initConsensusManager();
setUpRPCService();
+
+ LOGGER.info("Common configuration: " + COMMON_CONFIG.getConfigMessage());
+ LOGGER.info("ConfigNode configuration: " + CONFIG_NODE_CONFIG.getConfigMessage());
LOGGER.info(
"{} has successfully restarted and joined the cluster: {}.",
ConfigNodeConstant.GLOBAL_NAME,
@@ -148,6 +151,8 @@ public class ConfigNode implements ConfigNodeMBean {
setUpRPCService();
// The initial startup of Seed-ConfigNode finished
+ LOGGER.info("Common configuration: " + COMMON_CONFIG.getConfigMessage());
+ LOGGER.info("ConfigNode configuration: " + CONFIG_NODE_CONFIG.getConfigMessage());
LOGGER.info(
"{} has successfully started and joined the cluster: {}.",
ConfigNodeConstant.GLOBAL_NAME,
diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceProcessor.java b/confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceProcessor.java
index 809038da38..4d538b0bdc 100644
--- a/confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceProcessor.java
+++ b/confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceProcessor.java
@@ -24,13 +24,16 @@ import org.apache.iotdb.common.rpc.thrift.TFlushReq;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
import org.apache.iotdb.common.rpc.thrift.TSetTTLReq;
import org.apache.iotdb.commons.auth.AuthException;
+import org.apache.iotdb.commons.conf.CommonConfig;
import org.apache.iotdb.commons.conf.CommonDescriptor;
import org.apache.iotdb.commons.consensus.ConsensusGroupId;
import org.apache.iotdb.commons.path.PartialPath;
import org.apache.iotdb.commons.path.PathPatternTree;
import org.apache.iotdb.commons.utils.StatusUtils;
import org.apache.iotdb.commons.utils.TestOnly;
+import org.apache.iotdb.confignode.conf.ConfigNodeConfig;
import org.apache.iotdb.confignode.conf.ConfigNodeConstant;
+import org.apache.iotdb.confignode.conf.ConfigNodeDescriptor;
import org.apache.iotdb.confignode.conf.SystemPropertiesUtils;
import org.apache.iotdb.confignode.consensus.request.ConfigPhysicalPlanType;
import org.apache.iotdb.confignode.consensus.request.auth.AuthorPlan;
@@ -170,6 +173,10 @@ public class ConfigNodeRPCServiceProcessor implements IConfigNodeRPCService.Ifac
private static final Logger LOGGER = LoggerFactory.getLogger(ConfigNodeRPCServiceProcessor.class);
+ private static final CommonConfig COMMON_CONFIG = CommonDescriptor.getInstance().getConf();
+ private static final ConfigNodeConfig CONFIG_NODE_CONFIG =
+ ConfigNodeDescriptor.getInstance().getConf();
+
private final ConfigManager configManager;
public ConfigNodeRPCServiceProcessor(ConfigManager configManager) {
@@ -483,6 +490,9 @@ public class ConfigNodeRPCServiceProcessor implements IConfigNodeRPCService.Ifac
}
// The initial startup of Non-Seed-ConfigNode finished
+
+ LOGGER.info("Common configuration: " + COMMON_CONFIG.getConfigMessage());
+ LOGGER.info("ConfigNode configuration: " + CONFIG_NODE_CONFIG.getConfigMessage());
LOGGER.info(
"{} has successfully started and joined the cluster: {}.",
ConfigNodeConstant.GLOBAL_NAME,
diff --git a/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java b/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java
index ef86f184f9..0b6435e592 100644
--- a/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java
+++ b/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java
@@ -33,6 +33,8 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.File;
+import java.lang.reflect.Field;
+import java.util.Arrays;
import java.util.concurrent.TimeUnit;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
@@ -2550,4 +2552,29 @@ public class CommonConfig {
int maxClientCountForEachNodeInClientManager) {
this.maxClientCountForEachNodeInClientManager = maxClientCountForEachNodeInClientManager;
}
+
+ public String getConfigMessage() {
+ StringBuilder configMessage = new StringBuilder();
+ String configContent;
+ for (Field configField : CommonConfig.class.getDeclaredFields()) {
+ try {
+ String configType = configField.getGenericType().getTypeName();
+ if (configType.contains("java.lang.String[]")) {
+ String[] configList = (String[]) configField.get(this);
+ configContent = Arrays.asList(configList).toString();
+ } else {
+ configContent = configField.get(this).toString();
+ }
+ configMessage
+ .append("\n\t")
+ .append(configField.getName())
+ .append("=")
+ .append(configContent)
+ .append(";");
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+ return configMessage.toString();
+ }
}
diff --git a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
index 772bd57fa7..151f69737b 100644
--- a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
+++ b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
@@ -1416,7 +1416,7 @@ public class IoTDBConfig {
}
public String getConfigMessage() {
- String configMessage = "";
+ StringBuilder configMessage = new StringBuilder();
String configContent;
String[] notShowArray = {
"NODE_NAME_MATCHER",
@@ -1440,12 +1440,17 @@ public class IoTDBConfig {
} else {
configContent = configField.get(this).toString();
}
- configMessage = configMessage + configField.getName() + "=" + configContent + "; ";
+ configMessage
+ .append("\n\t")
+ .append(configField.getName())
+ .append("=")
+ .append(configContent)
+ .append(";");
} catch (Exception e) {
e.printStackTrace();
}
}
- return configMessage;
+ return configMessage.toString();
}
public long getCqMinEveryIntervalInMs() {
diff --git a/server/src/main/java/org/apache/iotdb/db/service/DataNode.java b/server/src/main/java/org/apache/iotdb/db/service/DataNode.java
index f0d356a609..b009e15c45 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/DataNode.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/DataNode.java
@@ -84,6 +84,8 @@ import org.apache.iotdb.db.wal.WALManager;
import org.apache.iotdb.metrics.config.MetricConfigDescriptor;
import org.apache.iotdb.metrics.utils.InternalReporterType;
import org.apache.iotdb.rpc.TSStatusCode;
+import org.apache.iotdb.tsfile.common.conf.TSFileConfig;
+import org.apache.iotdb.tsfile.common.conf.TSFileDescriptor;
import org.apache.iotdb.udf.api.exception.UDFManagementException;
import org.apache.thrift.TException;
@@ -104,6 +106,7 @@ public class DataNode implements DataNodeMBean {
private static final Logger logger = LoggerFactory.getLogger(DataNode.class);
private static final CommonConfig COMMON_CONFIG = CommonDescriptor.getInstance().getConf();
+ private static final TSFileConfig TSFILE_CONFIG = TSFileDescriptor.getInstance().getConfig();
private static final IoTDBConfig IOTDB_CONFIG = IoTDBDescriptor.getInstance().getConf();
private final String mbeanName =
@@ -176,6 +179,8 @@ public class DataNode implements DataNodeMBean {
// Setup metric service
setUpMetricService();
+ logger.info("Common configuration: " + COMMON_CONFIG.getConfigMessage());
+ logger.info("TSFile configuration: " + TSFILE_CONFIG.getConfigMessage());
logger.info("IoTDB configuration: " + IOTDB_CONFIG.getConfigMessage());
logger.info("Congratulation, IoTDB DataNode is set up successfully. Now, enjoy yourself!");
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/common/conf/TSFileConfig.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/common/conf/TSFileConfig.java
index bfc6119d92..e57b54ac28 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/common/conf/TSFileConfig.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/common/conf/TSFileConfig.java
@@ -23,7 +23,9 @@ import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
import org.apache.iotdb.tsfile.fileSystem.FSType;
import java.io.Serializable;
+import java.lang.reflect.Field;
import java.nio.charset.Charset;
+import java.util.Arrays;
import java.util.Properties;
/** TSFileConfig is a configuration class. Every variable is public and has default value. */
@@ -485,4 +487,29 @@ public class TSFileConfig implements Serializable {
public void setMaxTsBlockLineNumber(int maxTsBlockLineNumber) {
this.maxTsBlockLineNumber = maxTsBlockLineNumber;
}
+
+ public String getConfigMessage() {
+ StringBuilder configMessage = new StringBuilder();
+ String configContent;
+ for (Field configField : TSFileConfig.class.getDeclaredFields()) {
+ try {
+ String configType = configField.getGenericType().getTypeName();
+ if (configType.contains("java.lang.String[]")) {
+ String[] configList = (String[]) configField.get(this);
+ configContent = Arrays.asList(configList).toString();
+ } else {
+ configContent = configField.get(this).toString();
+ }
+ configMessage
+ .append("\n\t")
+ .append(configField.getName())
+ .append("=")
+ .append(configContent)
+ .append(";");
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+ return configMessage.toString();
+ }
}
[iotdb] 01/04: stash
Posted by yo...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a commit to branch Fix-configuration-error
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit b1ed94f3ed44010fcc052ff4467f7f42ab1184a3
Author: YongzaoDan <53...@qq.com>
AuthorDate: Tue Jan 17 17:36:57 2023 +0800
stash
---
.../src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java b/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java
index 50801663c1..ef86f184f9 100644
--- a/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java
+++ b/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java
@@ -635,6 +635,8 @@ public class CommonConfig {
private int coreClientCountForEachNodeInClientManager = 200;
private int maxClientCountForEachNodeInClientManager = 300;
+ private final long maxBytesPerFragmentInstance = allocateMemoryForDataExchange / queryThreadCount;
+
public CommonConfig() {
// Empty constructor
}
@@ -1708,9 +1710,8 @@ public class CommonConfig {
this.allocateMemoryForDataExchange = allocateMemoryForDataExchange;
}
- /** Get max bytes of each fragmentInstance for DataExchange. */
public long getMaxBytesPerFragmentInstance() {
- return allocateMemoryForDataExchange / queryThreadCount;
+ return maxBytesPerFragmentInstance;
}
public long getAllocateMemoryForTimeIndex() {
[iotdb] 03/04: stash
Posted by yo...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a commit to branch Fix-configuration-error
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 3dac9cb5d0b82b1e93cb8c9b7d0ca9b61b8d067b
Author: YongzaoDan <53...@qq.com>
AuthorDate: Tue Jan 17 18:10:46 2023 +0800
stash
---
.../main/java/org/apache/iotdb/commons/conf/CommonConfig.java | 10 +++++++++-
1 file changed, 9 insertions(+), 1 deletion(-)
diff --git a/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java b/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java
index 0b6435e592..9f7c9c2ebe 100644
--- a/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java
+++ b/node-commons/src/main/java/org/apache/iotdb/commons/conf/CommonConfig.java
@@ -35,6 +35,7 @@ import org.slf4j.LoggerFactory;
import java.io.File;
import java.lang.reflect.Field;
import java.util.Arrays;
+import java.util.List;
import java.util.concurrent.TimeUnit;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
@@ -408,7 +409,7 @@ public class CommonConfig {
private String iotdbServerEncryptDecryptProvider =
"org.apache.iotdb.commons.security.encrypt.MessageDigestEncrypt";
// Encryption provided class parameter
- private String iotdbServerEncryptDecryptProviderParameter;
+ private String iotdbServerEncryptDecryptProviderParameter = null;
// Cache size of user and role
private int authorCacheSize = 100;
@@ -2556,8 +2557,14 @@ public class CommonConfig {
public String getConfigMessage() {
StringBuilder configMessage = new StringBuilder();
String configContent;
+ String[] notShowArray = {"statusReason", "iotdbServerEncryptDecryptProviderParameter"};
+ List<String> notShowStrings = Arrays.asList(notShowArray);
for (Field configField : CommonConfig.class.getDeclaredFields()) {
try {
+ String configFieldString = configField.getName();
+ if (notShowStrings.contains(configFieldString)) {
+ continue;
+ }
String configType = configField.getGenericType().getTypeName();
if (configType.contains("java.lang.String[]")) {
String[] configList = (String[]) configField.get(this);
@@ -2572,6 +2579,7 @@ public class CommonConfig {
.append(configContent)
.append(";");
} catch (Exception e) {
+ logger.info("configFieldString: {}", configField.getName());
e.printStackTrace();
}
}
[iotdb] 04/04: Update ClientPoolFactory.java
Posted by yo...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a commit to branch Fix-configuration-error
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 71824140f6135adfebe4d13df843a02d2fbc3226
Author: YongzaoDan <53...@qq.com>
AuthorDate: Tue Jan 17 19:55:27 2023 +0800
Update ClientPoolFactory.java
---
.../apache/iotdb/commons/client/ClientPoolFactory.java | 17 ++++++++++++-----
1 file changed, 12 insertions(+), 5 deletions(-)
diff --git a/node-commons/src/main/java/org/apache/iotdb/commons/client/ClientPoolFactory.java b/node-commons/src/main/java/org/apache/iotdb/commons/client/ClientPoolFactory.java
index 2c73ea9880..52df84b786 100644
--- a/node-commons/src/main/java/org/apache/iotdb/commons/client/ClientPoolFactory.java
+++ b/node-commons/src/main/java/org/apache/iotdb/commons/client/ClientPoolFactory.java
@@ -41,6 +41,8 @@ public class ClientPoolFactory {
private static final CommonConfig conf = CommonDescriptor.getInstance().getConf();
+ private static int DEFAULT_SELECTOR_THREAD_COUNT_OF_CLIENT_MANAGER = 1;
+
private ClientPoolFactory() {}
public static class SyncConfigNodeIServiceClientPoolFactory
@@ -76,7 +78,8 @@ public class ClientPoolFactory {
new ThriftClientProperty.Builder()
.setConnectionTimeoutMs(conf.getConnectionTimeoutInMS())
.setRpcThriftCompressionEnabled(conf.isRpcThriftCompressionEnable())
- .setSelectorNumOfAsyncClientManager(conf.getSelectorThreadCountOfClientManager())
+ .setSelectorNumOfAsyncClientManager(
+ DEFAULT_SELECTOR_THREAD_COUNT_OF_CLIENT_MANAGER)
.build(),
ThreadName.ASYNC_CONFIGNODE_CLIENT_POOL.getName()),
new ClientPoolProperty.Builder<AsyncConfigNodeIServiceClient>()
@@ -120,7 +123,8 @@ public class ClientPoolFactory {
new ThriftClientProperty.Builder()
.setConnectionTimeoutMs(conf.getConnectionTimeoutInMS())
.setRpcThriftCompressionEnabled(conf.isRpcThriftCompressionEnable())
- .setSelectorNumOfAsyncClientManager(conf.getSelectorThreadCountOfClientManager())
+ .setSelectorNumOfAsyncClientManager(
+ DEFAULT_SELECTOR_THREAD_COUNT_OF_CLIENT_MANAGER)
.build(),
ThreadName.ASYNC_DATANODE_CLIENT_POOL.getName()),
new ClientPoolProperty.Builder<AsyncDataNodeInternalServiceClient>()
@@ -143,7 +147,8 @@ public class ClientPoolFactory {
new ThriftClientProperty.Builder()
.setConnectionTimeoutMs(conf.getConnectionTimeoutInMS())
.setRpcThriftCompressionEnabled(conf.isRpcThriftCompressionEnable())
- .setSelectorNumOfAsyncClientManager(conf.getSelectorThreadCountOfClientManager())
+ .setSelectorNumOfAsyncClientManager(
+ DEFAULT_SELECTOR_THREAD_COUNT_OF_CLIENT_MANAGER)
.build(),
ThreadName.ASYNC_CONFIGNODE_HEARTBEAT_CLIENT_POOL.getName()),
new ClientPoolProperty.Builder<AsyncConfigNodeHeartbeatServiceClient>()
@@ -166,7 +171,8 @@ public class ClientPoolFactory {
new ThriftClientProperty.Builder()
.setConnectionTimeoutMs(conf.getConnectionTimeoutInMS())
.setRpcThriftCompressionEnabled(conf.isRpcThriftCompressionEnable())
- .setSelectorNumOfAsyncClientManager(conf.getSelectorThreadCountOfClientManager())
+ .setSelectorNumOfAsyncClientManager(
+ DEFAULT_SELECTOR_THREAD_COUNT_OF_CLIENT_MANAGER)
.build(),
ThreadName.ASYNC_DATANODE_HEARTBEAT_CLIENT_POOL.getName()),
new ClientPoolProperty.Builder<AsyncDataNodeHeartbeatServiceClient>()
@@ -210,7 +216,8 @@ public class ClientPoolFactory {
new ThriftClientProperty.Builder()
.setConnectionTimeoutMs(conf.getConnectionTimeoutInMS())
.setRpcThriftCompressionEnabled(conf.isRpcThriftCompressionEnable())
- .setSelectorNumOfAsyncClientManager(conf.getSelectorThreadCountOfClientManager())
+ .setSelectorNumOfAsyncClientManager(
+ DEFAULT_SELECTOR_THREAD_COUNT_OF_CLIENT_MANAGER)
.build(),
ThreadName.ASYNC_DATANODE_MPP_DATA_EXCHANGE_CLIENT_POOL.getName()),
new ClientPoolProperty.Builder<AsyncDataNodeMPPDataExchangeServiceClient>()