diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java index 067c31f26be488..e7a72755a03b2f 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java @@ -416,7 +416,8 @@ public boolean isSyncLoadKindStmt() { LogicalPlan logicalPlan = ((LogicalPlanAdapter) parsedStmt).getLogicalPlan(); return logicalPlan instanceof InsertIntoTableCommand; } - return parsedStmt instanceof InsertStmt || parsedStmt instanceof CreateTableAsSelectStmt; + return parsedStmt instanceof InsertStmt || parsedStmt instanceof InsertOverwriteTableStmt + || parsedStmt instanceof CreateTableAsSelectStmt; } public boolean isAnalyzeStmt() {