diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/txn/Transaction.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/txn/Transaction.java index 94d1aa72702778..994f5e36055f17 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/txn/Transaction.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/txn/Transaction.java @@ -198,7 +198,8 @@ public void executeInsertIntoTableCommand(StmtExecutor executor) { // 2. transaction failed but Config.using_old_load_usage_pattern is true. // we will record the load job info for these 2 cases try { - StatementBase statement = planner.getCascadesContext().getStatementContext().getParsedStatement(); + // the statement parsed by Nereids is saved at executor::parsedStmt. + StatementBase statement = executor.getParsedStmt(); ctx.getEnv().getLoadManager() .recordFinishedLoadJob(labelName, txnId, database.getFullName(), table.getId(),