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));
}
}