This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch cp_fix_connection_leak in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 4679f195e8e54dd176a3ae5f7961dd41a33458ff Author: Haonan <[email protected]> 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 448f9af356f..baa30e84131 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 @@ -160,6 +160,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(
