fix

Caideyipi · Caideyipi · commit d6931f768171 · 2025-12-26T14:27:05.000+08:00
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
@@ -255,7 +255,7 @@ protected Optional<PipeWritePlanEvent> trimRealtimeEventByPrivilege(
     }
     if (!Boolean.FALSE.equals(isTableDatabasePlan)) {
       final Optional<ConfigPhysicalPlan> result =
-          TABLE_PRIVILEGE_PARSE_VISITOR.process(plan, userName);
+          TABLE_PRIVILEGE_PARSE_VISITOR.process(plan, userEntity);
       if (result.isPresent()) {
         return Optional.of(
             new PipeConfigRegionWritePlanEvent(result.get(), event.isGeneratedByPipe()));

Original file line number	Diff line number	Diff line change
`@@ -255,7 +255,7 @@ protected Optional<PipeWritePlanEvent> trimRealtimeEventByPrivilege(`
`255`	`255`	`}`
`256`	`256`	`if (!Boolean.FALSE.equals(isTableDatabasePlan)) {`
`257`	`257`	`final Optional<ConfigPhysicalPlan> result =`
`258`		`- TABLE_PRIVILEGE_PARSE_VISITOR.process(plan, userName);`
	`258`	`+ TABLE_PRIVILEGE_PARSE_VISITOR.process(plan, userEntity);`
`259`	`259`	`if (result.isPresent()) {`
`260`	`260`	`return Optional.of(`
`261`	`261`	`new PipeConfigRegionWritePlanEvent(result.get(), event.isGeneratedByPipe()));`