This is an automated email from the ASF dual-hosted git repository.
hello-stephen 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 4106b17900f [fix](regression) Wait for schema change in
rewrite_when_dml (#65408)
4106b17900f is described below
commit 4106b17900f43589e684d85502b71b453320ac64
Author: shuke <[email protected]>
AuthorDate: Fri Jul 10 11:35:41 2026 +0800
[fix](regression) Wait for schema change in rewrite_when_dml (#65408)
### What problem does this PR solve?
Problem Summary:
The `rewrite_when_dml` regression case waits for MTMV build tasks, but
it did not wait for column schema-change jobs after ALTER statements. On
Cloud P0, a later ALTER can run while the table is still in
`SCHEMA_CHANGE` and fail with `Table[orders]'s state(SCHEMA_CHANGE) is
not NORMAL`.
This patch waits for the latest column schema-change job to finish after
each ALTER in this case before continuing with MV rewrite checks.
---
.../nereids_rules_p0/mv/dml/rewrite/rewrite_when_dml.groovy | 9 +++++++++
1 file changed, 9 insertions(+)
diff --git
a/regression-test/suites/nereids_rules_p0/mv/dml/rewrite/rewrite_when_dml.groovy
b/regression-test/suites/nereids_rules_p0/mv/dml/rewrite/rewrite_when_dml.groovy
index c1c00d44863..80fede581be 100644
---
a/regression-test/suites/nereids_rules_p0/mv/dml/rewrite/rewrite_when_dml.groovy
+++
b/regression-test/suites/nereids_rules_p0/mv/dml/rewrite/rewrite_when_dml.groovy
@@ -177,6 +177,9 @@ suite("rewrite_when_dml") {
"""
order_qt_query1_0_before "${query1_0}"
sql """ALTER TABLE orders ADD COLUMN new_col INT KEY DEFAULT "0";"""
+ waitForSchemaChangeDone {
+ sql """SHOW ALTER TABLE COLUMN WHERE TableName='orders' ORDER BY
CreateTime DESC LIMIT 1"""
+ }
async_mv_rewrite_success(db, mv1_0, query1_0, "mv1_0")
order_qt_query1_0_after "${query1_0}"
sql """ DROP MATERIALIZED VIEW IF EXISTS mv1_0"""
@@ -231,6 +234,9 @@ suite("rewrite_when_dml") {
"""
waitingMTMVTaskFinishedByMvName("mv2_0")
sql """ALTER TABLE lineitem DROP COLUMN l_suppkey;"""
+ waitForSchemaChangeDone {
+ sql """SHOW ALTER TABLE COLUMN WHERE TableName='lineitem' ORDER BY
CreateTime DESC LIMIT 1"""
+ }
try {
mv_not_part_in(query2_0, "mv2_0")
@@ -284,6 +290,9 @@ suite("rewrite_when_dml") {
"""
waitingMTMVTaskFinishedByMvName("mv3_0")
sql """ALTER TABLE orders DROP COLUMN O_COMMENT;"""
+ waitForSchemaChangeDone {
+ sql """SHOW ALTER TABLE COLUMN WHERE TableName='orders' ORDER BY
CreateTime DESC LIMIT 1"""
+ }
mv_not_part_in(query3_0, "mv3_0")
order_qt_query3_0_after "${query3_0}"
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
