This is an automated email from the ASF dual-hosted git repository. caogaofei pushed a commit to branch beyyes/rel_1.1_fix_connection in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 9cfc16b3de5d48189f7059940d6306c0cb056dbe Author: Beyyes <[email protected]> AuthorDate: Mon May 29 19:37:42 2023 +0800 [IOTDB-5794] Filter session connection whose username is empty when using the method of sessionPool.fetchAllConnections() --- .../src/main/java/org/apache/iotdb/db/query/control/SessionManager.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/server/src/main/java/org/apache/iotdb/db/query/control/SessionManager.java b/server/src/main/java/org/apache/iotdb/db/query/control/SessionManager.java index a0ba7d8d379..005d6f401ae 100644 --- a/server/src/main/java/org/apache/iotdb/db/query/control/SessionManager.java +++ b/server/src/main/java/org/apache/iotdb/db/query/control/SessionManager.java @@ -42,6 +42,7 @@ import org.apache.iotdb.service.rpc.thrift.TSConnectionInfo; import org.apache.iotdb.service.rpc.thrift.TSConnectionInfoResp; import org.apache.iotdb.service.rpc.thrift.TSProtocolVersion; +import org.apache.commons.lang.StringUtils; import org.apache.thrift.TException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -375,6 +376,7 @@ public class SessionManager implements SessionManagerMBean { public TSConnectionInfoResp getAllConnectionInfo() { return new TSConnectionInfoResp( sessions.keySet().stream() + .filter(s -> StringUtils.isNotEmpty(s.getUsername())) .map(IClientSession::convertToTSConnectionInfo) .sorted(Comparator.comparingLong(TSConnectionInfo::getLogInTime)) .collect(Collectors.toList()));
