(iotdb) branch master updated: Fix SessionConnection opens too much transport without closing (#15649)

[haonan]

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

haonan 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 ab653b4bf58 Fix SessionConnection opens too much transport without 
closing (#15649)
ab653b4bf58 is described below

commit ab653b4bf583cccc9d4823e4641fd1c3f8e18d4c
Author: Haonan <hhao...@outlook.com>
AuthorDate: Fri Jun 6 13:28:20 2025 +0800

    Fix SessionConnection opens too much transport without closing (#15649)
---
 .../src/main/java/org/apache/iotdb/session/SessionConnection.java      | 3 +++
 1 file changed, 3 insertions(+)

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 491071f093a..4d4fdc28041 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
@@ -182,6 +182,9 @@ public class SessionConnection {
     
DeepCopyRpcTransportFactory.setDefaultBufferCapacity(session.thriftDefaultBufferSize);
     
DeepCopyRpcTransportFactory.setThriftMaxFrameSize(session.thriftMaxFrameSize);
     try {
+      if (transport != null && transport.isOpen()) {
+        close();
+      }
       if (useSSL) {
         transport =
             DeepCopyRpcTransportFactory.INSTANCE.getTransport(