This is an automated email from the ASF dual-hosted git repository.

tanxinyu 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 cc1842c5906 Fixed the bug that TimeoutChangeableTFastFramedTransport 
is unused so that timeout changing is disabled in thrift transferring (#12186)
cc1842c5906 is described below

commit cc1842c5906dc42b02c9200a2a28b5fbb622a74e
Author: Caideyipi <[email protected]>
AuthorDate: Mon Mar 18 14:28:50 2024 +0800

    Fixed the bug that TimeoutChangeableTFastFramedTransport is unused so that 
timeout changing is disabled in thrift transferring (#12186)
---
 .../src/main/java/org/apache/iotdb/rpc/DeepCopyRpcTransportFactory.java | 2 +-
 .../src/main/java/org/apache/iotdb/rpc/ZeroCopyRpcTransportFactory.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/DeepCopyRpcTransportFactory.java
 
b/iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/DeepCopyRpcTransportFactory.java
index 83f41275f2e..37fba22b124 100644
--- 
a/iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/DeepCopyRpcTransportFactory.java
+++ 
b/iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/DeepCopyRpcTransportFactory.java
@@ -40,7 +40,7 @@ public class DeepCopyRpcTransportFactory extends 
BaseRpcTransportFactory {
                 new TimeoutChangeableTSnappyFramedTransport.Factory(
                     thriftDefaultBufferSize, thriftMaxFrameSize, true))
             : new DeepCopyRpcTransportFactory(
-                new TElasticFramedTransport.Factory(
+                new TimeoutChangeableTFastFramedTransport.Factory(
                     thriftDefaultBufferSize, thriftMaxFrameSize, true));
   }
 }
diff --git 
a/iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/ZeroCopyRpcTransportFactory.java
 
b/iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/ZeroCopyRpcTransportFactory.java
index 69ad7068cc5..de132ba72e1 100644
--- 
a/iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/ZeroCopyRpcTransportFactory.java
+++ 
b/iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/ZeroCopyRpcTransportFactory.java
@@ -40,7 +40,7 @@ public class ZeroCopyRpcTransportFactory extends 
BaseRpcTransportFactory {
                 new TimeoutChangeableTSnappyFramedTransport.Factory(
                     thriftDefaultBufferSize, thriftMaxFrameSize, false))
             : new ZeroCopyRpcTransportFactory(
-                new TElasticFramedTransport.Factory(
+                new TimeoutChangeableTFastFramedTransport.Factory(
                     thriftDefaultBufferSize, thriftMaxFrameSize, false));
   }
 }

Reply via email to