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 45fa34d60a7357..6f000786fa9cc1 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};"