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 fd338a80ad..871b71d2dd 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 @@ -596,7 +596,7 @@ public class StmtExecutor implements ProfileWriter { handleTransactionStmt(); } else if (parsedStmt instanceof CreateTableAsSelectStmt) { handleCtasStmt(); - } else if (parsedStmt instanceof InsertStmt) { // Must ahead of DdlStmt because InserStmt is its subclass + } else if (parsedStmt instanceof InsertStmt) { // Must ahead of DdlStmt because InsertStmt is its subclass try { handleInsertStmt(); if (!((InsertStmt) parsedStmt).getQueryStmt().isExplain()) { @@ -1551,7 +1551,7 @@ public class StmtExecutor implements ProfileWriter { executor.beginTransaction(request); } - // Process a select statement. + // Process an insert statement. private void handleInsertStmt() throws Exception { // Every time set no send flag and clean all data in buffer if (context.getMysqlChannel() != null) {