permission-change

Author: Caideyipi

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/IoTDBConfigRegionSource.java

@@ -246,7 +246,8 @@ protected Optional<PipeWritePlanEvent> trimRealtimeEventByPrivilege(
         ((PipeConfigRegionWritePlanEvent) event).getConfigPhysicalPlan();
     final Boolean isTableDatabasePlan = isTableDatabasePlan(plan);
     if (!Boolean.TRUE.equals(isTableDatabasePlan)) {
-      final Optional<ConfigPhysicalPlan> result = treePrivilegeParseVisitor.process(plan, userName);
+      final Optional<ConfigPhysicalPlan> result =
+          treePrivilegeParseVisitor.process(plan, userEntity);
       if (result.isPresent()) {
         return Optional.of(
             new PipeConfigRegionWritePlanEvent(result.get(), event.isGeneratedByPipe()));