[iotdb] branch rel/1.1 updated: [To rel/1.1][IOTDB-5794] Filter session connection whose username is empty when using the method of sessionPool.fetchAllConnections() (#9974)

[haonan]

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

haonan pushed a commit to branch rel/1.1
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/rel/1.1 by this push:
     new c9bd1a58796 [To rel/1.1][IOTDB-5794] Filter session connection whose 
username is empty when using the method of sessionPool.fetchAllConnections() 
(#9974)
c9bd1a58796 is described below

commit c9bd1a587965eb2536ebf267a29d2c5eada4ae9c
Author: Beyyes <cgf1...@foxmail.com>
AuthorDate: Wed May 31 10:29:22 2023 +0800

    [To rel/1.1][IOTDB-5794] Filter session connection whose username is empty 
when using the method of sessionPool.fetchAllConnections() (#9974)
---
 .../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()));