From 9f38dfc100348df4794b24263c50fc56fea591d0 Mon Sep 17 00:00:00 2001 From: Chen Zhang Date: Fri, 5 Jan 2024 17:10:40 +0800 Subject: [PATCH] Revert "[fix](regression) Fix flaky test test_partial_update_2pc_schema_change (#29037)" This reverts commit ffa3c319ddfca2934eed5c683b906b9b4b93f34c. --- .../test_partial_update_2pc_schema_change.groovy | 9 ++++----- 1 file changed, 4 insertions(+), 5 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 6f000786fa9cc1..45fa34d60a7357 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,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;""" @@ -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() @@ -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', ',' @@ -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};"