This is an automated email from the ASF dual-hosted git repository.
zhangchen 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 ffa3c319ddf [fix](regression) Fix flaky test
test_partial_update_2pc_schema_change (#29037)
ffa3c319ddf is described below
commit ffa3c319ddfca2934eed5c683b906b9b4b93f34c
Author: bobhan1 <[email protected]>
AuthorDate: Tue Dec 26 21:43:14 2023 +0800
[fix](regression) Fix flaky test test_partial_update_2pc_schema_change
(#29037)
---
.../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]
