Skip to content

Commit

Permalink
Revert "[fix](regression) Fix flaky test test_partial_update_2pc_sche…
Browse files Browse the repository at this point in the history
…ma_change (apache#29037)"

This reverts commit ffa3c31.
  • Loading branch information
zhannngchen committed Jan 5, 2024
1 parent fa47211 commit 9f38dfc
Showing 1 changed file with 4 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -72,7 +72,6 @@ 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 @@ -154,7 +153,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 @@ -166,7 +165,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 @@ -177,11 +176,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 9f38dfc

Please sign in to comment.