Skip to content

Commit

Permalink
[fix](regression) Fix flaky test test_partial_update_2pc_schema_change (
Browse files Browse the repository at this point in the history
  • Loading branch information
bobhan1 authored and stephen committed Dec 28, 2023
1 parent a400529 commit 3f3d0a6
Showing 1 changed file with 5 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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;"""


Expand Down Expand Up @@ -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()

Expand All @@ -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', ','
Expand All @@ -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};"
Expand Down

0 comments on commit 3f3d0a6

Please sign in to comment.