[case](fix) add sync after stream load (#22601)

regression-test/suites/load_p0/stream_load/test_json_load.groovy

@@ -606,9 +606,10 @@ suite("test_json_load", "p0") {
             "replication_num" = "1"
         );
         """
-1
+
         load_json_data.call("${testTable}", 'with_jsonpath', '', 'true', 'json', """productid, deviceid, data, datatimestamp, dt=from_unixtime(substr(datatimestamp,1,10),'%Y%m%d')""",
                 '["$.productid","$.deviceid","$.data","$.data.datatimestamp"]', '', '', '', 'with_jsonpath.json')
+        sql "sync"
         qt_select22 "select * from ${testTable}"
 
     } finally {

regression-test/suites/partition_p0/list_partition/test_list_partition_datatype.groovy

@@ -74,6 +74,7 @@ suite("test_list_partition_datatype", "p0") {
                 assertEquals(15, json.NumberLoadedRows)
             }
         }
+        sql """sync"""
         test {
             sql "SELECT * FROM ${tableName} ORDER BY k1, k2"
             resultFile "expect_baseall.out"

regression-test/suites/partition_p0/test_partition_operation.groovy

@@ -44,6 +44,7 @@ suite("test_partition_operation", "p1") {
             set "column_separator", ","
             file "./multi_partition/partition_table.csv"
         }
+        sql """sync"""
         test {
             sql "select * from ${tableName} order by k1, k2"
             resultFile "./multi_partition/partition_table.out"

regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update.groovy

@@ -172,7 +172,7 @@ suite("test_primary_key_partial_update", "p0") {
             assertEquals(2, json.NumberFilteredRows)
         }
     }
-
+    sql "sync"
     qt_partial_update_in_one_stream_load """
         select * from ${tableName} order by id;
     """

regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_delete.groovy

@@ -92,6 +92,7 @@ suite('test_partial_update_delete') {
         file 'partial_update_delete.csv'
         time 10000
     }
+    sql "sync"
     qt_sql "select k1,c1,c2,c3,c4 from ${tableName3} order by k1,c1,c2,c3,c4;"
     sql "set skip_delete_sign=true;"
     sql "set skip_storage_engine_merge=true;"

regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_parallel.groovy

@@ -82,6 +82,8 @@ suite("test_primary_key_partial_update_parallel", "p0") {
         }
     }
 
+    sql "sync"
+
     sql """
         select * from ${tableName} order by id;
     """

regression-test/suites/unique_with_mow_p0/partial_update/test_partial_update_upsert.groovy

@@ -99,5 +99,6 @@ suite("test_partial_update_upsert", "p0") {
             assertEquals("fail", json.Status.toLowerCase())
         }
     }
+    sql "sync"
     sql """ DROP TABLE IF EXISTS ${tableName2} """
 }