fix

924060929 · Dec 20, 2024 · 4e2e3bd · 4e2e3bd
1 parent 1916b8c
commit 4e2e3bd
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/...ain/java/org/apache/doris/nereids/trees/plans/commands/insert/InsertIntoTableCommand.java b/...ain/java/org/apache/doris/nereids/trees/plans/commands/insert/InsertIntoTableCommand.java
@@ -217,7 +217,6 @@ public AbstractInsertExecutor initPlan(ConnectContext ctx, StmtExecutor stmtExec
             insertExecutor.getCoordinator().setTxnId(insertExecutor.getTxnId());
             stmtExecutor.setCoord(insertExecutor.getCoordinator());
             // for prepare and execute, avoiding normalization for every execute command
-            this.originalLogicalQuery = this.logicalQuery;
             return insertExecutor;
         }
         LOG.warn("insert plan failed {} times. query id is {}.", retryTimes, DebugUtil.printId(ctx.queryId()));
@@ -238,12 +237,12 @@ private BuildInsertExecutorResult initPlanOnce(ConnectContext ctx,
             if (cte.isPresent()) {
                 this.logicalQuery = Optional.of((LogicalPlan) cte.get().withChildren(logicalQuery.get()));
             }
-            OlapGroupCommitInsertExecutor.analyzeGroupCommit(ctx, targetTableIf, this.logicalQuery, this.insertCtx);
+            OlapGroupCommitInsertExecutor.analyzeGroupCommit(ctx, targetTableIf, this.logicalQuery.get(), this.insertCtx);
         } finally {
             targetTableIf.readUnlock();
         }
 
-        LogicalPlanAdapter logicalPlanAdapter = new LogicalPlanAdapter(logicalQuery, ctx.getStatementContext());
+        LogicalPlanAdapter logicalPlanAdapter = new LogicalPlanAdapter(logicalQuery.get(), ctx.getStatementContext());
         return planInsertExecutor(ctx, stmtExecutor, logicalPlanAdapter, targetTableIf);
     }