This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch ReflectBug in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit ae8c510cd693c9979e25de550ee141786f0cedd4 Author: JackieTien97 <[email protected]> AuthorDate: Tue May 3 15:06:49 2022 +0800 Fix Reflection can't find constructor bug --- .../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,
