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

justinchen pushed a commit to branch enable-time-other-name
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/enable-time-other-name by this 
push:
     new b895cd074e0 fix
b895cd074e0 is described below

commit b895cd074e0b772fba99306d0f083d4d0f7e3249
Author: Caideyipi <[email protected]>
AuthorDate: Fri Dec 26 12:28:03 2025 +0800

    fix
---
 .../pipe/source/PipeConfigTreePrivilegeParseVisitor.java       | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/PipeConfigTreePrivilegeParseVisitor.java
 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/PipeConfigTreePrivilegeParseVisitor.java
index e86981acffb..2f1ca01e13b 100644
--- 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/PipeConfigTreePrivilegeParseVisitor.java
+++ 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/PipeConfigTreePrivilegeParseVisitor.java
@@ -51,6 +51,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import java.io.IOException;
+import java.util.Arrays;
 import java.util.Collections;
 import java.util.HashMap;
 import java.util.List;
@@ -362,16 +363,23 @@ public class PipeConfigTreePrivilegeParseVisitor
   @Override
   public Optional<ConfigPhysicalPlan> visitTTL(
       final SetTTLPlan setTTLPlan, final IAuditEntity userEntity) {
+    final CNAuditLogger logger = 
ConfigNode.getInstance().getConfigManager().getAuditLogger();
+    userEntity.setPrivilegeType(PrivilegeType.READ_SCHEMA);
+    final String auditObject = Arrays.toString(setTTLPlan.getPathPattern());
     try {
       final List<PartialPath> paths =
           getAllIntersectedPatterns(
               new PartialPath(setTTLPlan.getPathPattern()), userEntity, 
setTTLPlan);
       // The intersectionList is either a singleton list or an empty list, 
because the pipe
       // pattern and TTL path are each either a prefix path or a full path
-      return !paths.isEmpty() && paths.get(0).getNodeLength() == 
setTTLPlan.getPathPattern().length
+      final boolean result =
+          !paths.isEmpty() && paths.get(0).getNodeLength() == 
setTTLPlan.getPathPattern().length;
+      logger.recordAuditLog(userEntity.setResult(result), () -> auditObject);
+      return result
           ? Optional.of(new SetTTLPlan(paths.get(0).getNodes(), 
setTTLPlan.getTTL()))
           : Optional.empty();
     } catch (final AuthException e) {
+      logger.recordAuditLog(userEntity.setResult(false), () -> auditObject);
       if (skip) {
         return Optional.empty();
       } else {

Reply via email to