This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch fix_SessionConnection in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 303f14ed7ebb18d111be98318574f7669a876855 Author: HTHou <[email protected]> AuthorDate: Thu Jun 5 16:33:46 2025 +0800 Fix SessionConnection opens too much transport without closing --- .../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(
