This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch ty/benchant
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/ty/benchant by this push:
new 659b08be5ac remove cglib dependency
659b08be5ac is described below
commit 659b08be5ac5dfcd7eb32d4cf708595f992f5308
Author: JackieTien97 <[email protected]>
AuthorDate: Mon Jun 5 14:02:26 2023 +0800
remove cglib dependency
---
.../iot/client/SyncIoTConsensusServiceClient.java | 17 +++++++++--------
.../client/sync/SyncConfigNodeIServiceClient.java | 16 +++++++++-------
.../client/sync/SyncDataNodeInternalServiceClient.java | 16 +++++++++-------
.../sync/SyncDataNodeMPPDataExchangeServiceClient.java | 17 ++++++++++-------
server/pom.xml | 7 +++++++
.../org/apache/iotdb/db/client/ConfigNodeClient.java | 13 ++++++++-----
6 files changed, 52 insertions(+), 34 deletions(-)
diff --git
a/consensus/src/main/java/org/apache/iotdb/consensus/iot/client/SyncIoTConsensusServiceClient.java
b/consensus/src/main/java/org/apache/iotdb/consensus/iot/client/SyncIoTConsensusServiceClient.java
index e3815d3c3e5..14dc5bac8dd 100644
---
a/consensus/src/main/java/org/apache/iotdb/consensus/iot/client/SyncIoTConsensusServiceClient.java
+++
b/consensus/src/main/java/org/apache/iotdb/consensus/iot/client/SyncIoTConsensusServiceClient.java
@@ -24,7 +24,6 @@ import org.apache.iotdb.commons.client.ClientManager;
import org.apache.iotdb.commons.client.ThriftClient;
import org.apache.iotdb.commons.client.factory.ThriftClientFactory;
import org.apache.iotdb.commons.client.property.ThriftClientProperty;
-import org.apache.iotdb.commons.client.sync.SyncThriftClientWithErrorHandler;
import org.apache.iotdb.consensus.iot.thrift.IoTConsensusIService;
import org.apache.iotdb.rpc.RpcTransportFactory;
import org.apache.iotdb.rpc.TConfigurationConst;
@@ -106,13 +105,15 @@ public class SyncIoTConsensusServiceClient extends
IoTConsensusIService.Client
public PooledObject<SyncIoTConsensusServiceClient> makeObject(TEndPoint
endpoint)
throws Exception {
return new DefaultPooledObject<>(
- SyncThriftClientWithErrorHandler.newErrorHandler(
- SyncIoTConsensusServiceClient.class,
- SyncIoTConsensusServiceClient.class.getConstructor(
- thriftClientProperty.getClass(), endpoint.getClass(),
clientManager.getClass()),
- thriftClientProperty,
- endpoint,
- clientManager));
+ new SyncIoTConsensusServiceClient(thriftClientProperty, endpoint,
clientManager));
+ // SyncThriftClientWithErrorHandler.newErrorHandler(
+ // SyncIoTConsensusServiceClient.class,
+ // SyncIoTConsensusServiceClient.class.getConstructor(
+ // thriftClientProperty.getClass(), endpoint.getClass(),
+ // clientManager.getClass()),
+ // thriftClientProperty,
+ // endpoint,
+ // clientManager));
}
@Override
diff --git
a/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncConfigNodeIServiceClient.java
b/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncConfigNodeIServiceClient.java
index 4e1df10520a..2881ee4051d 100644
---
a/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncConfigNodeIServiceClient.java
+++
b/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncConfigNodeIServiceClient.java
@@ -116,13 +116,15 @@ public class SyncConfigNodeIServiceClient extends
IConfigNodeRPCService.Client
public PooledObject<SyncConfigNodeIServiceClient> makeObject(TEndPoint
endpoint)
throws Exception {
return new DefaultPooledObject<>(
- SyncThriftClientWithErrorHandler.newErrorHandler(
- SyncConfigNodeIServiceClient.class,
- SyncConfigNodeIServiceClient.class.getConstructor(
- thriftClientProperty.getClass(), endpoint.getClass(),
clientManager.getClass()),
- thriftClientProperty,
- endpoint,
- clientManager));
+ new SyncConfigNodeIServiceClient(thriftClientProperty, endpoint,
clientManager));
+ // SyncThriftClientWithErrorHandler.newErrorHandler(
+ // SyncConfigNodeIServiceClient.class,
+ // SyncConfigNodeIServiceClient.class.getConstructor(
+ // thriftClientProperty.getClass(), endpoint.getClass(),
+ // clientManager.getClass()),
+ // thriftClientProperty,
+ // endpoint,
+ // clientManager));
}
@Override
diff --git
a/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncDataNodeInternalServiceClient.java
b/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncDataNodeInternalServiceClient.java
index 2b90b5b2661..030812955b3 100644
---
a/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncDataNodeInternalServiceClient.java
+++
b/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncDataNodeInternalServiceClient.java
@@ -128,13 +128,15 @@ public class SyncDataNodeInternalServiceClient extends
IDataNodeRPCService.Clien
public PooledObject<SyncDataNodeInternalServiceClient>
makeObject(TEndPoint endpoint)
throws Exception {
return new DefaultPooledObject<>(
- SyncThriftClientWithErrorHandler.newErrorHandler(
- SyncDataNodeInternalServiceClient.class,
- SyncDataNodeInternalServiceClient.class.getConstructor(
- thriftClientProperty.getClass(), endpoint.getClass(),
clientManager.getClass()),
- thriftClientProperty,
- endpoint,
- clientManager));
+ new SyncDataNodeInternalServiceClient(thriftClientProperty,
endpoint, clientManager));
+ // SyncThriftClientWithErrorHandler.newErrorHandler(
+ // SyncDataNodeInternalServiceClient.class,
+ // SyncDataNodeInternalServiceClient.class.getConstructor(
+ // thriftClientProperty.getClass(), endpoint.getClass(),
+ // clientManager.getClass()),
+ // thriftClientProperty,
+ // endpoint,
+ // clientManager));
}
@Override
diff --git
a/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncDataNodeMPPDataExchangeServiceClient.java
b/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncDataNodeMPPDataExchangeServiceClient.java
index 024b7515fc8..a9228973bda 100644
---
a/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncDataNodeMPPDataExchangeServiceClient.java
+++
b/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncDataNodeMPPDataExchangeServiceClient.java
@@ -117,13 +117,16 @@ public class SyncDataNodeMPPDataExchangeServiceClient
extends MPPDataExchangeSer
public PooledObject<SyncDataNodeMPPDataExchangeServiceClient>
makeObject(TEndPoint endpoint)
throws Exception {
return new DefaultPooledObject<>(
- SyncThriftClientWithErrorHandler.newErrorHandler(
- SyncDataNodeMPPDataExchangeServiceClient.class,
- SyncDataNodeMPPDataExchangeServiceClient.class.getConstructor(
- thriftClientProperty.getClass(), endpoint.getClass(),
clientManager.getClass()),
- thriftClientProperty,
- endpoint,
- clientManager));
+ new SyncDataNodeMPPDataExchangeServiceClient(
+ thriftClientProperty, endpoint, clientManager));
+ // SyncThriftClientWithErrorHandler.newErrorHandler(
+ // SyncDataNodeMPPDataExchangeServiceClient.class,
+ //
SyncDataNodeMPPDataExchangeServiceClient.class.getConstructor(
+ // thriftClientProperty.getClass(), endpoint.getClass(),
+ // clientManager.getClass()),
+ // thriftClientProperty,
+ // endpoint,
+ // clientManager));
}
@Override
diff --git a/server/pom.xml b/server/pom.xml
index f185a813b6d..e27e84bdbd7 100644
--- a/server/pom.xml
+++ b/server/pom.xml
@@ -473,6 +473,13 @@
<buildArg>--verbose</buildArg>
<buildArg>--initialize-at-build-time=ch.qos.logback,fresh.graal,io.micronau,org.slf4j</buildArg>
<buildArg>--initialize-at-run-time=io.netty</buildArg>
+ <buildArg>-J-XX:+UseParallelGC</buildArg>
+
<buildArg>-J--add-opens=java.base/java.util.concurrent=ALL-UNNAMED</buildArg>
+
<buildArg>-J--add-opens=java.base/java.lang=ALL-UNNAMED</buildArg>
+
<buildArg>-J--add-opens=java.base/java.util=ALL-UNNAMED</buildArg>
+
<buildArg>-J--add-opens=java.base/java.nio=ALL-UNNAMED</buildArg>
+
<buildArg>-J--add-opens=java.base/java.io=ALL-UNNAMED</buildArg>
+
<buildArg>-J--add-opens=java.base/java.net=ALL-UNNAMED</buildArg>
<!--
<buildArg>--initialize-at-run-time=io.micronaut.configuration.metrics,io.micrometer,io.netty</buildArg>-->
<!-- For Quick Build (22.1+) -->
<buildArg>-Ob</buildArg>
diff --git
a/server/src/main/java/org/apache/iotdb/db/client/ConfigNodeClient.java
b/server/src/main/java/org/apache/iotdb/db/client/ConfigNodeClient.java
index f9d69c2caa4..cb585efcaf2 100644
--- a/server/src/main/java/org/apache/iotdb/db/client/ConfigNodeClient.java
+++ b/server/src/main/java/org/apache/iotdb/db/client/ConfigNodeClient.java
@@ -31,7 +31,6 @@ import org.apache.iotdb.commons.client.ClientManager;
import org.apache.iotdb.commons.client.ThriftClient;
import org.apache.iotdb.commons.client.factory.ThriftClientFactory;
import org.apache.iotdb.commons.client.property.ThriftClientProperty;
-import org.apache.iotdb.commons.client.sync.SyncThriftClientWithErrorHandler;
import org.apache.iotdb.commons.consensus.ConfigRegionId;
import org.apache.iotdb.confignode.rpc.thrift.IConfigNodeRPCService;
import org.apache.iotdb.confignode.rpc.thrift.TAddConsensusGroupReq;
@@ -2241,13 +2240,17 @@ public class ConfigNodeClient implements
IConfigNodeRPCService.Iface, ThriftClie
public PooledObject<ConfigNodeClient> makeObject(ConfigRegionId
configRegionId)
throws Exception {
return new DefaultPooledObject<>(
- SyncThriftClientWithErrorHandler.newErrorHandler(
- ConfigNodeClient.class,
- ConfigNodeClient.class.getConstructor(
- List.class, thriftClientProperty.getClass(),
clientManager.getClass()),
+ new ConfigNodeClient(
ConfigNodeInfo.getInstance().getLatestConfigNodes(),
thriftClientProperty,
clientManager));
+ // SyncThriftClientWithErrorHandler.newErrorHandler(
+ // ConfigNodeClient.class,
+ // ConfigNodeClient.class.getConstructor(
+ // List.class, thriftClientProperty.getClass(),
clientManager.getClass()),
+ // ConfigNodeInfo.getInstance().getLatestConfigNodes(),
+ // thriftClientProperty,
+ // clientManager));
}
@Override
