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 edc55dba0da43a..9a6e6a4d68f39b 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 @@ -407,7 +407,8 @@ public boolean isSyncLoadKindStmt() { || (logicalPlan instanceof CreateTableCommand && ((CreateTableCommand) logicalPlan).isCtasCommand()); } - return parsedStmt instanceof InsertStmt || parsedStmt instanceof CreateTableAsSelectStmt; + return parsedStmt instanceof InsertStmt || parsedStmt instanceof InsertOverwriteTableStmt + || parsedStmt instanceof CreateTableAsSelectStmt; } public boolean isAnalyzeStmt() {