(iotdb) branch fix-ts-n updated: fix

[justinchen]

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

justinchen pushed a commit to branch fix-ts-n
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/fix-ts-n by this push:
     new 9d374645f1d fix
9d374645f1d is described below

commit 9d374645f1dc33ebe27d975faf0712e8568ce3a3
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Thu Jan 22 14:38:52 2026 +0800

    fix
---
 .../common/tablet/PipeInsertNodeTabletInsertionEvent.java | 15 ++++++++-------
 1 file changed, 8 insertions(+), 7 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeInsertNodeTabletInsertionEvent.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeInsertNodeTabletInsertionEvent.java
index 19881c955f0..b576ac507b8 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeInsertNodeTabletInsertionEvent.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeInsertNodeTabletInsertionEvent.java
@@ -287,9 +287,6 @@ public class PipeInsertNodeTabletInsertionEvent extends 
PipeInsertionEvent
 
   @Override
   public void throwIfNoPrivilege() throws Exception {
-    if (skipIfNoPrivileges) {
-      return;
-    }
     final InsertNode node = insertNode;
     if (Objects.isNull(node)) {
       // Event is released, skip privilege check
@@ -320,10 +317,14 @@ public class PipeInsertNodeTabletInsertionEvent extends 
PipeInsertionEvent
             userName,
             new QualifiedObjectName(getTableModelDatabaseName(), tableName),
             new UserEntity(Long.parseLong(userId), userName, cliHostname))) {
-      throw new AccessDeniedException(
-          String.format(
-              "No privilege for SELECT for user %s at table %s.%s",
-              userName, tableModelDatabaseName, tableName));
+      if (skipIfNoPrivileges) {
+        shouldParse4Privilege = true;
+      } else {
+        throw new AccessDeniedException(
+            String.format(
+                "No privilege for SELECT for user %s at table %s.%s",
+                userName, tableModelDatabaseName, tableName));
+      }
     }
   }