This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch ExternalRPCService_no_timeout in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 65e37bde681ca2788fd23d71785b1ea0163029a4 Author: HTHou <[email protected]> AuthorDate: Mon Oct 20 09:38:59 2025 +0800 Set ExternalRPCService server connection with ssl no timeout --- .../src/main/java/org/apache/iotdb/db/service/ExternalRPCService.java | 1 - .../java/org/apache/iotdb/commons/service/ThriftServiceThread.java | 3 +-- 2 files changed, 1 insertion(+), 3 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/ExternalRPCService.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/ExternalRPCService.java index f17cbb67d8b..dcc8690de8a 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/ExternalRPCService.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/ExternalRPCService.java @@ -79,7 +79,6 @@ public class ExternalRPCService extends ThriftService implements ExternalRPCServ config.isRpcThriftCompressionEnable(), commonConfig.getKeyStorePath(), commonConfig.getKeyStorePwd(), - config.getConnectionTimeoutInMS(), ZeroCopyRpcTransportFactory.INSTANCE) : new ThriftServiceThread( processor, diff --git a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/service/ThriftServiceThread.java b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/service/ThriftServiceThread.java index 1daaba5313a..ea340d5e636 100644 --- a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/service/ThriftServiceThread.java +++ b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/service/ThriftServiceThread.java @@ -99,7 +99,6 @@ public class ThriftServiceThread extends AbstractThriftServiceThread { boolean compress, String keyStorePath, String keyStorePwd, - int clientTimeout, TTransportFactory transportFactory) { super( processor, @@ -115,7 +114,7 @@ public class ThriftServiceThread extends AbstractThriftServiceThread { keyStorePwd, null, null, - clientTimeout, + 0, transportFactory); }
