diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/InsertIntoTableCommand.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/InsertIntoTableCommand.java index 3ac25f371aed33..399d4970f5bf71 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/InsertIntoTableCommand.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/InsertIntoTableCommand.java @@ -345,12 +345,13 @@ private BuildInsertExecutorResult initPlanOnce(ConnectContext ctx, } OlapGroupCommitInsertExecutor.analyzeGroupCommit( ctx, targetTableIf, this.logicalQuery.get(), this.insertCtx); + + LogicalPlanAdapter logicalPlanAdapter + = new LogicalPlanAdapter(logicalQuery.get(), ctx.getStatementContext()); + return planInsertExecutor(ctx, stmtExecutor, logicalPlanAdapter, targetTableIf); } finally { targetTableIf.readUnlock(); } - - LogicalPlanAdapter logicalPlanAdapter = new LogicalPlanAdapter(logicalQuery.get(), ctx.getStatementContext()); - return planInsertExecutor(ctx, stmtExecutor, logicalPlanAdapter, targetTableIf); } // we should select the factory type first, but we can not initial InsertExecutor at this time,