This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch fix-audit
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/fix-audit by this push:
new e8ac44ca278 fix
e8ac44ca278 is described below
commit e8ac44ca278b6566f2d1b0b2f590dd33bdde546f
Author: Caideyipi <[email protected]>
AuthorDate: Wed Feb 25 10:57:07 2026 +0800
fix
---
.../iotdb/confignode/manager/pipe/source/IoTDBConfigRegionSource.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/IoTDBConfigRegionSource.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/IoTDBConfigRegionSource.java
index 60512887703..24a9a220de7 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/IoTDBConfigRegionSource.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/IoTDBConfigRegionSource.java
@@ -327,7 +327,8 @@ public class IoTDBConfigRegionSource extends
IoTDBNonDataRegionSource {
final IoTDBTreePatternOperations treePattern,
final TablePattern tablePattern) {
final Boolean isTableDatabasePlan = isTableDatabasePlan(plan);
- return listenedTypeSet.contains(plan.getType())
+ return ConfigRegionListeningFilter.shouldPlanBeListened(plan)
+ && listenedTypeSet.contains(plan.getType())
&& (Objects.isNull(isTableDatabasePlan)
|| Boolean.TRUE.equals(isTableDatabasePlan)
&& tablePattern.isTableModelDataAllowedToBeCaptured()
