[test](regression) add 'sync' for som stream load (#27357)

regression-test/suites/delete_p0/test_delete_where_in.groovy

@@ -69,6 +69,9 @@ suite("test_delete_where_in", "delete_p0") {
                 assertTrue(json.NumberLoadedRows > 0 && json.LoadBytes > 0)
             }
         }
+
+        sql """ sync; """
+
         def loadRowCount = sql "select count(*) from ${tb_name};"
         logger.info("select count(*) from ${loadRowCount};")
         

regression-test/suites/demo_p0/streamLoad_action.groovy

@@ -66,6 +66,8 @@ suite("streamLoad_action") {
         directToBe  backendIps.get(backendId),  backendHttpPorts.get(backendId) as int
     }
 
+    sql """ sync; """
+
     order_qt_select_1 "SELECT * FROM ${tableName}"
     sql "TRUNCATE TABLE ${tableName}"
 

regression-test/suites/export_p0/test_export_empty_table.groovy

@@ -189,6 +189,8 @@ suite("test_export_empty_table", "p0") {
             }
         }
 
+        sql """ sync; """
+
         qt_select_load1 """ SELECT * FROM ${table_load_name} t ORDER BY user_id; """
     
     } finally {

regression-test/suites/export_p0/test_export_orc.groovy

@@ -202,6 +202,8 @@ suite("test_export_orc", "p0") {
             }
         }
 
+        sql """ sync; """
+
         qt_select_load1 """ SELECT * FROM ${table_load_name} t ORDER BY user_id; """
     
     } finally {

regression-test/suites/export_p0/test_outfile_separator.groovy

@@ -93,6 +93,8 @@ suite("test_outfile_separator") {
             time 10000 // limit inflight 10s
         }
 
+        sql """ sync; """
+
         qt_select_2 """ SELECT * FROM ${tableName} t ORDER BY k1; """
 
     } finally {

regression-test/suites/json_p0/test_json_load_and_function.groovy

@@ -99,6 +99,8 @@ suite("test_json_load_and_function", "p0") {
         }
     }
 
+    sql """ sync; """
+
     // check result
     qt_select "SELECT * FROM ${testTable} ORDER BY id"
 

regression-test/suites/jsonb_p0/test_jsonb_load_and_function.groovy

@@ -100,6 +100,8 @@ suite("test_jsonb_load_and_function", "p0") {
         }
     }
 
+    sql """ sync; """
+
     // check result
     qt_select "SELECT * FROM ${testTable} ORDER BY id"
 

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

@@ -121,9 +121,11 @@ suite("test_stream_load", "p0") {
             assertEquals(1, json.NumberFilteredRows)
         }
     }
-    qt_sql_strict_mode_ratio "select * from ${tableName} order by k1, k2"
 
     sql "sync"
+
+    qt_sql_strict_mode_ratio "select * from ${tableName} order by k1, k2"
+
     sql """ DROP TABLE IF EXISTS ${tableName} """
     sql """
         CREATE TABLE IF NOT EXISTS ${tableName} (

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

@@ -161,6 +161,9 @@ suite("test_primary_key_partial_update_seq_col", "p0") {
                 file 'basic.csv'
                 time 10000 // limit inflight 10s
             }
+
+            sql "sync"
+
             qt_sql """ select id,score from ${tableName2} order by id;"""
             sql """ DROP TABLE IF EXISTS ${tableName2}; """
         }