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();