From ffa3c319ddfca2934eed5c683b906b9b4b93f34c Mon Sep 17 00:00:00 2001
From: bobhan1 <bh2444151092@outlook.com>
Date: Tue, 26 Dec 2023 21:43:14 +0800
Subject: [PATCH] [fix](regression) Fix flaky test
 test_partial_update_2pc_schema_change (#29037)

---
 .../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 45fa34d60a..6f000786fa 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};"