(iotdb) branch master updated: fix: remove mqtt with table auth check (#15288)

[critas]

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

critas 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 b466bd1c699 fix: remove mqtt with table auth check (#15288)
b466bd1c699 is described below

commit b466bd1c699b8122fd264a7de9e9cecf9aca76a7
Author: CritasWang <cri...@outlook.com>
AuthorDate: Mon Apr 7 18:46:53 2025 +0800

    fix: remove mqtt with table auth check (#15288)
    
    * fix: remove mqtt with table auth check
    
    * spotless
---
 .../iotdb/db/protocol/mqtt/MPPPublishHandler.java  | 45 ++++++++++------------
 1 file changed, 20 insertions(+), 25 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/mqtt/MPPPublishHandler.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/mqtt/MPPPublishHandler.java
index ac3a82d9730..288efb85d6d 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/mqtt/MPPPublishHandler.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/mqtt/MPPPublishHandler.java
@@ -172,32 +172,27 @@ public class MPPPublishHandler extends 
AbstractInterceptHandler {
     try {
       TimestampPrecisionUtils.checkTimestampPrecision(message.getTimestamp());
       InsertTabletStatement insertTabletStatement = 
constructInsertTabletStatement(message);
-      tsStatus = AuthorityChecker.checkAuthority(insertTabletStatement, 
session);
-      if (tsStatus.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
-        LOG.warn(tsStatus.message);
-      } else {
-        session.setDatabaseName(message.getDatabase().toLowerCase());
-        session.setSqlDialect(IClientSession.SqlDialect.TABLE);
-        long queryId = sessionManager.requestQueryId();
-        SqlParser relationSqlParser = new SqlParser();
-        Metadata metadata = LocalExecutionPlanner.getInstance().metadata;
-        ExecutionResult result =
-            Coordinator.getInstance()
-                .executeForTableModel(
-                    insertTabletStatement,
-                    relationSqlParser,
-                    session,
-                    queryId,
-                    sessionManager.getSessionInfo(session),
-                    "",
-                    metadata,
-                    config.getQueryTimeoutThreshold());
+      session.setDatabaseName(message.getDatabase().toLowerCase());
+      session.setSqlDialect(IClientSession.SqlDialect.TABLE);
+      long queryId = sessionManager.requestQueryId();
+      SqlParser relationSqlParser = new SqlParser();
+      Metadata metadata = LocalExecutionPlanner.getInstance().metadata;
+      ExecutionResult result =
+          Coordinator.getInstance()
+              .executeForTableModel(
+                  insertTabletStatement,
+                  relationSqlParser,
+                  session,
+                  queryId,
+                  sessionManager.getSessionInfo(session),
+                  "",
+                  metadata,
+                  config.getQueryTimeoutThreshold());
 
-        tsStatus = result.status;
-        LOG.debug("process result: {}", tsStatus);
-        if (tsStatus.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) 
{
-          LOG.warn("mqtt line insert error , message = {}", tsStatus.message);
-        }
+      tsStatus = result.status;
+      LOG.debug("process result: {}", tsStatus);
+      if (tsStatus.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
+        LOG.warn("mqtt line insert error , message = {}", tsStatus.message);
       }
     } catch (Exception e) {
       LOG.warn(