This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch mqtt_bug in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 19579a3878b323ee60ba22cde11c6d61e62ea0cb Author: JackieTien97 <[email protected]> AuthorDate: Wed Jun 11 19:15:32 2025 +0800 Remove ThreadLocal for Mqtt Client --- .../java/org/apache/iotdb/db/protocol/session/SessionManager.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) 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 4aa6c9db8a9..d7c5cb6f8be 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 @@ -360,11 +360,9 @@ public class SessionManager implements SessionManagerMBean { /** * this method can be only used in mqtt model. Do not use this method in client-thread model based * service. - * - * @return false if the session has been initialized. */ - public boolean registerSessionForMqtt(IClientSession session) { - return sessions.put(session, placeHolder) == null; + public void registerSessionForMqtt(IClientSession session) { + sessions.put(session, placeHolder); } /** must be called after registerSession()) will mark the session login. */
