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 0e01cdafd68 fix
0e01cdafd68 is described below
commit 0e01cdafd689417aa245d4779bfe4749a7211d64
Author: Caideyipi <[email protected]>
AuthorDate: Wed Jan 21 10:26:32 2026 +0800
fix
---
.../parser/scan/TsFileInsertionEventScanParser.java | 17 +++++++++++++++++
1 file changed, 17 insertions(+)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/scan/TsFileInsertionEventScanParser.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/scan/TsFileInsertionEventScanParser.java
index 8590fe2002e..6fad3440a34 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/scan/TsFileInsertionEventScanParser.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/scan/TsFileInsertionEventScanParser.java
@@ -604,6 +604,23 @@ public class TsFileInsertionEventScanParser extends
TsFileInsertionEventParser {
}
}
+ if (Objects.nonNull(entity)) {
+ final TSStatus status =
+ AuthorityChecker.getAccessControl()
+ .checkSeriesPrivilege4Pipe(
+ entity,
+ Collections.singletonList(
+ new MeasurementPath(currentDevice,
chunkHeader.getMeasurementID())),
+ PrivilegeType.READ_DATA);
+ if (status.getCode() !=
TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
+ if (skipIfNoPrivileges) {
+ tsFileSequenceReader.position(nextMarkerOffset);
+ break;
+ }
+ throw new AccessDeniedException(status.getMessage());
+ }
+ }
+
// Increase value index
final int valueIndex =
measurementIndexMap.compute(
