This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new 45d3c28200a [branch-2.0-pick] PIcks "[fix](regression) Fix flaky test
test_partial_update_2pc_schema_change #29037" (#29038)
45d3c28200a is described below
commit 45d3c28200abe823b284527673e8a0ad9d56e32e
Author: bobhan1 <[email protected]>
AuthorDate: Tue Dec 26 15:22:16 2023 +0800
[branch-2.0-pick] PIcks "[fix](regression) Fix flaky test
test_partial_update_2pc_schema_change #29037" (#29038)
---
.../partial_update/test_partial_update_2pc_schema_change.groovy | 9 +++++----
1 file changed, 5 insertions(+), 4 deletions(-)
diff --git
a/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_2pc_schema_change.groovy
b/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_2pc_schema_change.groovy
index 45fa34d60a7..6f000786fa9 100644
---
a/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_2pc_schema_change.groovy
+++
b/regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_2pc_schema_change.groovy
@@ -72,6 +72,7 @@ suite("test_partial_update_2pc_schema_change", "p0") {
file 'concurrency_update3.csv'
time 10000 // limit inflight 10s
}
+ sql "sync;"
qt_sql """ select * from ${tableName} order by k1;"""
@@ -153,7 +154,7 @@ suite("test_partial_update_2pc_schema_change", "p0") {
assertEquals("success", json.Status.toLowerCase())
}
}
-
+ sql "sync;"
sql """ alter table ${tableName} modify column v2 varchar(40);"""
wait_for_schema_change()
@@ -165,7 +166,7 @@ suite("test_partial_update_2pc_schema_change", "p0") {
sql """ alter table ${tableName} rename column v4 renamed_v4;"""
wait_for_schema_change()
-
+ sql "sync;"
streamLoad {
table "${tableName}"
set 'column_separator', ','
@@ -176,11 +177,11 @@ suite("test_partial_update_2pc_schema_change", "p0") {
file 'concurrency_update2.csv'
time 10000 // limit inflight 10s
}
-
+ sql "sync;"
qt_sql """ select * from ${tableName} order by k1;"""
do_streamload_2pc(txnId, "commit", tableName)
-
+ sql "sync;"
qt_sql """ select * from ${tableName} order by k1;"""
sql "drop table if exists ${tableName};"
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
