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

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

@@ -53,7 +53,6 @@ suite("streamLoad_action") {
         // stream load action will check result, include Success status, and NumberTotalRows == NumberLoadedRows
     }
 
-
     // stream load 100 rows
     def rowCount = 100
     // range: [0, rowCount)

regression-test/suites/export_p0/test_export_empty_table.groovy

@@ -184,6 +184,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

@@ -197,6 +197,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

@@ -88,6 +88,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

@@ -95,6 +95,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

@@ -96,6 +96,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

@@ -92,6 +92,7 @@ suite("test_stream_load", "p0") {
     }
 
     sql "sync"
+
     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}; """
         }