fix

Author: Caideyipi

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/PipeTsFileInsertionEvent.java

@@ -99,6 +99,8 @@ public class PipeTsFileInsertionEvent extends PipeInsertionEvent
 
   protected volatile ProgressIndex overridingProgressIndex;
   private Set<String> tableNames;
+
+  // This is set to check the tsFile paths by privilege
   private Map<IDeviceID, String[]> treeSchemaMap;
 
   public PipeTsFileInsertionEvent(

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/parser/ASTVisitor.java

@@ -4052,8 +4052,9 @@ public Statement visitCreatePipe(final IoTDBSqlParser.CreatePipeContext ctx) {
     final CreatePipeStatement createPipeStatement =
         new CreatePipeStatement(StatementType.CREATE_PIPE);
 
-    final String pipeName = parseIdentifier(ctx.pipeName.getText());
+    final String pipeName;
     if (ctx.pipeName != null) {
+      pipeName = parseIdentifier(ctx.pipeName.getText());
       createPipeStatement.setPipeName(pipeName);
     } else {
       throw new SemanticException(