This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 76604d50fd9 [fix](groupcommit) Fix insert_group_commit_into case
(#38201)
76604d50fd9 is described below
commit 76604d50fd99c017b139cf42129086dfbb580f6c
Author: meiyi <[email protected]>
AuthorDate: Mon Jul 22 19:23:32 2024 +0800
[fix](groupcommit) Fix insert_group_commit_into case (#38201)
Fix failed `insert_group_commit_into` due to schema change
---
.../trees/plans/commands/insert/OlapGroupCommitInsertExecutor.java | 7 +++++++
1 file changed, 7 insertions(+)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/OlapGroupCommitInsertExecutor.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/OlapGroupCommitInsertExecutor.java
index edf8251f97f..88ad9a00dff 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/OlapGroupCommitInsertExecutor.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/insert/OlapGroupCommitInsertExecutor.java
@@ -30,8 +30,10 @@ import org.apache.doris.common.util.DebugUtil;
import org.apache.doris.mtmv.MTMVUtil;
import org.apache.doris.nereids.NereidsPlanner;
import org.apache.doris.nereids.analyzer.UnboundTableSink;
+import org.apache.doris.nereids.exceptions.AnalysisException;
import org.apache.doris.nereids.trees.plans.algebra.OneRowRelation;
import org.apache.doris.nereids.trees.plans.logical.LogicalUnion;
+import org.apache.doris.planner.GroupCommitPlanner;
import org.apache.doris.qe.ConnectContext;
import org.apache.doris.qe.QueryState.MysqlStateType;
import org.apache.doris.qe.StmtExecutor;
@@ -71,6 +73,11 @@ public class OlapGroupCommitInsertExecutor extends
OlapInsertExecutor {
@Override
protected void beforeExec() {
+ if
(Env.getCurrentEnv().getGroupCommitManager().isBlock(this.table.getId())) {
+ String msg = "insert table " + this.table.getId() +
GroupCommitPlanner.SCHEMA_CHANGE;
+ LOG.info(msg);
+ throw new AnalysisException(msg);
+ }
try {
this.coordinator.setGroupCommitBe(Env.getCurrentEnv().getGroupCommitManager()
.selectBackendForGroupCommit(table.getId(), ctx, false));
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
