[chore](regression) Add 'sync' after stream_load in some cases (#18945)

apache · Apr 23, 2023 · 63e8fb7 · 63e8fb7
1 parent 166bed1
commit 63e8fb7
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/regression-test/suites/correctness_p0/test_current_timestamp.groovy b/regression-test/suites/correctness_p0/test_current_timestamp.groovy
@@ -78,6 +78,9 @@ suite("test_current_timestamp") {
 
         time 10000 // limit inflight 10s
     }
+
+    sql "sync"
+
     qt_stream_load_csv1 """ select count(*) from ${tableName} where id > 4 and to_date(dt_0) = to_date(dt_1); """
     qt_stream_load_csv2 """ select count(*) from ${tableName} where id > 4 and to_date(dt_2) = to_date(dt_3); """
     qt_stream_load_csv3 """ select count(*) from ${tableName} where id > 4 and to_date(dt_4) = to_date(dt_5); """
@@ -98,6 +101,9 @@ suite("test_current_timestamp") {
 
         time 10000 // limit inflight 10s
     }
+
+    sql "sync"
+
     qt_stream_load_json1 """ select count(*) from ${tableName} where id > 8 and to_date(dt_0) = to_date(dt_1); """
     qt_stream_load_json2 """ select count(*) from ${tableName} where id > 8 and to_date(dt_2) = to_date(dt_3); """
     qt_stream_load_json3 """ select count(*) from ${tableName} where id > 8 and to_date(dt_4) = to_date(dt_5); """
@@ -117,6 +123,9 @@ suite("test_current_timestamp") {
         file 'test_current_timestamp_streamload.json'
         time 10000 // limit inflight 10s
     }
+
+    sql "sync"
+
     qt_stream_load_json5 """ select id, name, dt_1  from ${tableName2} order by id; """
     qt_stream_load_json6 """ select count(*) from ${tableName2} where dt_2 is not NULL; """
  }
diff --git a/...est/suites/query_p0/sql_functions/aggregate_functions/test_aggregate_all_functions.groovy b/...est/suites/query_p0/sql_functions/aggregate_functions/test_aggregate_all_functions.groovy
@@ -530,6 +530,8 @@ suite("test_aggregate_all_functions") {
         inputIterator rows.iterator()
     }
 
+    sql "sync"
+
     qt_select48 """select dt, id, quantile_percent(quantile_union(price), 0) from ${tableName_21} group by dt, id order by dt, id"""
 
     qt_select49 """select dt, id, quantile_percent(quantile_union(price), 0.5) from ${tableName_21} group by dt, id order by dt, id"""