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 97585673e824..16cd1dc2f752 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 e5e95d4f82ca..db6955f6dc77 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 void supplySession( 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 TSConnectionInfoResp getAllConnectionInfo() { public List 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());