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

jackietien pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dev/1.3 by this push:
     new 4f6f4c8628e [To dev/1.3] Fix thread leak in session while connected DN 
is down
4f6f4c8628e is described below

commit 4f6f4c8628e587961f7455ad40c8707d313b94ea
Author: Jackie Tien <[email protected]>
AuthorDate: Wed Jun 18 16:33:30 2025 +0800

    [To dev/1.3] Fix thread leak in session while connected DN is down
---
 .../session/src/main/java/org/apache/iotdb/session/Session.java     | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/iotdb-client/session/src/main/java/org/apache/iotdb/session/Session.java 
b/iotdb-client/session/src/main/java/org/apache/iotdb/session/Session.java
index b7bf5daac0c..61625d1c59e 100644
--- a/iotdb-client/session/src/main/java/org/apache/iotdb/session/Session.java
+++ b/iotdb-client/session/src/main/java/org/apache/iotdb/session/Session.java
@@ -584,10 +584,10 @@ public class Session implements ISession {
 
   @Override
   public synchronized void close() throws IoTDBConnectionException {
-    if (isClosed) {
-      return;
-    }
     try {
+      if (isClosed) {
+        return;
+      }
       if (enableRedirection) {
         for (SessionConnection sessionConnection : 
endPointToSessionConnection.values()) {
           sessionConnection.close();

Reply via email to