This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch force_ci/object_type in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 75e8579e6008a5a10a921a59515dfef61a313e9a Author: libo <[email protected]> AuthorDate: Fri Dec 12 11:18:42 2025 +0800 Hotfix concurrent connect error (#16900) (cherry picked from commit fad9bdedada706c521393bc4b926c81763d7bdf4) --- .../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());
