This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch branch-2.0 in repository https://gitbox.apache.org/repos/asf/doris.git
commit be3ed9842ceef8c594b06b7333fbd5d4bfe2fc48 Author: Siyang Tang <[email protected]> AuthorDate: Mon Aug 21 14:59:27 2023 +0800 [fix](nereids) fix insert timeout loses effect with nereids (#23217) --- fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) 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 f8d1d94a97..d1da7f2b7d 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 @@ -126,6 +126,7 @@ import org.apache.doris.nereids.parser.NereidsParser; import org.apache.doris.nereids.stats.StatsErrorEstimator; import org.apache.doris.nereids.trees.plans.commands.Command; import org.apache.doris.nereids.trees.plans.commands.Forward; +import org.apache.doris.nereids.trees.plans.commands.InsertIntoTableCommand; import org.apache.doris.nereids.trees.plans.logical.LogicalPlan; import org.apache.doris.planner.OlapScanNode; import org.apache.doris.planner.OriginalPlanner; @@ -391,7 +392,14 @@ public class StmtExecutor { } public boolean isInsertStmt() { - return parsedStmt != null && parsedStmt instanceof InsertStmt; + if (parsedStmt == null) { + return false; + } + if (parsedStmt instanceof LogicalPlanAdapter) { + LogicalPlan logicalPlan = ((LogicalPlanAdapter) parsedStmt).getLogicalPlan(); + return logicalPlan instanceof InsertIntoTableCommand; + } + return parsedStmt instanceof InsertStmt; } /** --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
