(iotdb) branch master updated: Set MQTT address to empty string. (#17111)

[jackietien]

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

jackietien pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new ba95e5fd4c0 Set MQTT address to empty string. (#17111)
ba95e5fd4c0 is described below

commit ba95e5fd4c04a591fa65be624d1c3ebbdb86c5e1
Author: wenyanshi-123 <3463456...@qq.com>
AuthorDate: Thu Jan 29 19:57:47 2026 +0800

    Set MQTT address to empty string. (#17111)
    
    Co-authored-by: shiwenyan <wenyan....@timecho.com>
---
 .../mqtt/src/main/java/org/apache/iotdb/mqtt/MPPPublishHandler.java | 2 +-
 .../org/apache/iotdb/db/protocol/session/MqttClientSession.java     | 6 +++++-
 2 files changed, 6 insertions(+), 2 deletions(-)

diff --git 
a/external-service-impl/mqtt/src/main/java/org/apache/iotdb/mqtt/MPPPublishHandler.java
 
b/external-service-impl/mqtt/src/main/java/org/apache/iotdb/mqtt/MPPPublishHandler.java
index b13b1e89934..395447e9734 100644
--- 
a/external-service-impl/mqtt/src/main/java/org/apache/iotdb/mqtt/MPPPublishHandler.java
+++ 
b/external-service-impl/mqtt/src/main/java/org/apache/iotdb/mqtt/MPPPublishHandler.java
@@ -292,7 +292,7 @@ public class MPPPublishHandler extends 
AbstractInterceptHandler {
           AuthorityChecker.checkAuthority(
               statement,
               new TreeAccessCheckContext(
-                  session.getUserId(), session.getUsername(), 
session.getClientAddress()));
+                  session.getUserId(), session.getUsername(), 
session.getClientID()));
       if (tsStatus.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
         LOG.warn(tsStatus.message);
       } else {
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/session/MqttClientSession.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/session/MqttClientSession.java
index 41fc6447c23..85672852be2 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/session/MqttClientSession.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/session/MqttClientSession.java
@@ -26,6 +26,10 @@ import java.util.Set;
 
 public class MqttClientSession extends IClientSession {
 
+  public String getClientID() {
+    return clientID;
+  }
+
   private final String clientID;
 
   public MqttClientSession(String clientID) {
@@ -34,7 +38,7 @@ public class MqttClientSession extends IClientSession {
 
   @Override
   public String getClientAddress() {
-    return clientID;
+    return "";
   }
 
   @Override