ap

Author: Caideyipi

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

@@ -226,14 +226,14 @@ public Optional<ConfigPhysicalPlan> visitRevokeUser(
 
   @Override
   public Optional<ConfigPhysicalPlan> visitGrantRole(
-      final AuthorTreePlan revokeUserPlan, final String userName) {
-    return visitRolePlan(revokeUserPlan, userName);
+      final AuthorTreePlan grantRolePlan, final String userName) {
+    return visitRolePlan(grantRolePlan, userName);
   }
 
   @Override
   public Optional<ConfigPhysicalPlan> visitRevokeRole(
-      final AuthorTreePlan revokeUserPlan, final String userName) {
-    return visitRolePlan(revokeUserPlan, userName);
+      final AuthorTreePlan revokeRolePlan, final String userName) {
+    return visitRolePlan(revokeRolePlan, userName);
   }
 
   private Optional<ConfigPhysicalPlan> visitUserPlan(

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/auth/AuthorPlanExecutor.java

@@ -685,10 +685,10 @@ public TAuthizedPatternTreeResp generateAuthorizedPTree(String username, int per
   public PathPatternTree generateRawAuthorizedPTree(final String username, final PrivilegeType type)
       throws AuthException {
     final User user = authorizer.getUser(username);
-    final PathPatternTree pPtree = new PathPatternTree();
     if (user == null) {
       return null;
     }
+    final PathPatternTree pPtree = new PathPatternTree();
 
     constructAuthorityScope(pPtree, user, type);
 

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/writeback/WriteBackSink.java

@@ -187,7 +187,7 @@ public void customize(
             Arrays.asList(CONNECTOR_USE_EVENT_USER_NAME_KEY, SINK_USE_EVENT_USER_NAME_KEY),
             CONNECTOR_USE_EVENT_USER_NAME_DEFAULT_VALUE);
 
-    if (SESSION_MANAGER.getCurrSession() != null) {
+    if (SESSION_MANAGER.getCurrSession() == null) {
       SESSION_MANAGER.registerSession(session);
     }
   }