This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 18053aee25 Fix Reflection can't find constructor bug (#5776)
18053aee25 is described below
commit 18053aee255956ecd8a9eb83ea450e6023e8bd8d
Author: Jackie Tien <[email protected]>
AuthorDate: Tue May 3 15:13:35 2022 +0800
Fix Reflection can't find constructor bug (#5776)
---
.../iotdb/commons/client/sync/SyncConfigNodeIServiceClient.java | 5 +----
.../commons/client/sync/SyncDataNodeDataBlockServiceClient.java | 5 +----
2 files changed, 2 insertions(+), 8 deletions(-)
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 f57becd12c..8091839e43 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
@@ -105,10 +105,7 @@ public class SyncConfigNodeIServiceClient extends
ConfigIService.Client
throws Exception {
Constructor<SyncConfigNodeIServiceClient> constructor =
SyncConfigNodeIServiceClient.class.getConstructor(
- clientFactoryProperty.getProtocolFactory().getClass(),
- int.class,
- endpoint.getClass(),
- clientManager.getClass());
+ TProtocolFactory.class, int.class, endpoint.getClass(),
clientManager.getClass());
return new DefaultPooledObject<>(
SyncThriftClientWithErrorHandler.newErrorHandler(
SyncConfigNodeIServiceClient.class,
diff --git
a/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncDataNodeDataBlockServiceClient.java
b/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncDataNodeDataBlockServiceClient.java
index 6152614684..79b4da8547 100644
---
a/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncDataNodeDataBlockServiceClient.java
+++
b/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncDataNodeDataBlockServiceClient.java
@@ -106,10 +106,7 @@ public class SyncDataNodeDataBlockServiceClient extends
DataBlockService.Client
throws Exception {
Constructor<SyncDataNodeDataBlockServiceClient> constructor =
SyncDataNodeDataBlockServiceClient.class.getConstructor(
- clientFactoryProperty.getProtocolFactory().getClass(),
- int.class,
- endpoint.getClass(),
- clientManager.getClass());
+ TProtocolFactory.class, int.class, endpoint.getClass(),
clientManager.getClass());
return new DefaultPooledObject<>(
SyncThriftClientWithErrorHandler.newErrorHandler(
SyncDataNodeDataBlockServiceClient.class,