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 {