You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ta...@apache.org on 2024/03/18 06:28:56 UTC

(iotdb) branch master updated: Fixed the bug that TimeoutChangeableTFastFramedTransport is unused so that timeout changing is disabled in thrift transferring (#12186)

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 <87...@users.noreply.github.com>
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));
   }
 }