(iotdb) branch yym_rpc_compress updated: revert changes regarding compact protocol

[jiangtian]

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

jiangtian pushed a commit to branch yym_rpc_compress
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/yym_rpc_compress by this push:
     new cb602edcc53 revert changes regarding compact protocol
cb602edcc53 is described below

commit cb602edcc539eb272de51ed2e8bff35d8afa1e8e
Author: Tian Jiang <jt2594...@163.com>
AuthorDate: Mon Jul 14 17:28:56 2025 +0800

    revert changes regarding compact protocol
---
 .../src/main/java/org/apache/iotdb/session/SessionConnection.java  | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/iotdb-client/session/src/main/java/org/apache/iotdb/session/SessionConnection.java
 
b/iotdb-client/session/src/main/java/org/apache/iotdb/session/SessionConnection.java
index e027c310a4e..477eba234eb 100644
--- 
a/iotdb-client/session/src/main/java/org/apache/iotdb/session/SessionConnection.java
+++ 
b/iotdb-client/session/src/main/java/org/apache/iotdb/session/SessionConnection.java
@@ -69,6 +69,7 @@ import org.apache.iotdb.session.util.SessionUtils;
 
 import org.apache.thrift.TException;
 import org.apache.thrift.protocol.TBinaryProtocol;
+import org.apache.thrift.protocol.TCompactProtocol;
 import org.apache.thrift.transport.TTransport;
 import org.apache.thrift.transport.TTransportException;
 import org.apache.tsfile.utils.Pair;
@@ -206,7 +207,11 @@ public class SessionConnection {
       throw new IoTDBConnectionException(e);
     }
 
-    client = new IClientRPCService.Client(new TBinaryProtocol(transport));
+    if (session.enableRPCCompression) {
+      client = new IClientRPCService.Client(new TCompactProtocol(transport));
+    } else {
+      client = new IClientRPCService.Client(new TBinaryProtocol(transport));
+    }
     client = RpcUtils.newSynchronizedClient(client);
 
     TSOpenSessionReq openReq = new TSOpenSessionReq();