(iotdb) branch master updated: Hotfix concurrent connect error (#16900)

[jackietien]

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

jackietien 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 fad9bdedada Hotfix concurrent connect error (#16900)
fad9bdedada is described below

commit fad9bdedada706c521393bc4b926c81763d7bdf4
Author: libo <zerolbs...@163.com>
AuthorDate: Fri Dec 12 11:18:42 2025 +0800

    Hotfix concurrent connect error (#16900)
---
 .../java/org/apache/iotdb/db/protocol/session/IClientSession.java     | 3 ++-
 .../java/org/apache/iotdb/db/protocol/session/SessionManager.java     | 4 ++--
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/session/IClientSession.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/session/IClientSession.java
index 97585673e82..16cd1dc2f75 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/session/IClientSession.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/session/IClientSession.java
@@ -20,6 +20,7 @@
 package org.apache.iotdb.db.protocol.session;
 
 import org.apache.iotdb.commons.conf.IoTDBConstant.ClientVersion;
+import org.apache.iotdb.commons.utils.CommonDateTimeUtils;
 import org.apache.iotdb.db.queryengine.common.ConnectionInfo;
 import org.apache.iotdb.service.rpc.thrift.TSConnectionInfo;
 import org.apache.iotdb.service.rpc.thrift.TSConnectionType;
@@ -57,7 +58,7 @@ public abstract class IClientSession {
 
   @Nullable private String databaseName;
 
-  private long lastActiveTime;
+  private long lastActiveTime = CommonDateTimeUtils.currentTime();
 
   public abstract String getClientAddress();
 
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/session/SessionManager.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/session/SessionManager.java
index e5e95d4f82c..db6955f6dc7 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/session/SessionManager.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/session/SessionManager.java
@@ -497,8 +497,8 @@ public class SessionManager implements SessionManagerMBean {
     session.setUsername(username);
     session.setZoneId(zoneId);
     session.setClientVersion(clientVersion);
-    session.setLogin(true);
     session.setLogInTime(System.currentTimeMillis());
+    session.setLogin(true);
   }
 
   public void closeDataset(
@@ -581,7 +581,7 @@ public class SessionManager implements SessionManagerMBean {
 
   public List<ConnectionInfo> getAllSessionConnectionInfo() {
     return sessions.keySet().stream()
-        .filter(s -> StringUtils.isNotEmpty(s.getUsername()))
+        .filter(s -> StringUtils.isNotEmpty(s.getUsername()) && s.isLogin())
         .map(IClientSession::convertToConnectionInfo)
         .sorted(Comparator.comparingLong(ConnectionInfo::getLastActiveTime))
         .collect(Collectors.toList());