From 0694ae0ea83f8d36dc8f89abad99a830de0612b5 Mon Sep 17 00:00:00 2001
From: Jerry Hu <mrhhsg@gmail.com>
Date: Sun, 23 Apr 2023 11:51:24 +0800
Subject: [PATCH] [chore](regression) Add 'sync' after stream_load in some
 cases

---
 .../suites/correctness_p0/test_current_timestamp.groovy  | 9 +++++++++
 .../test_aggregate_all_functions.groovy                  | 2 ++
 2 files changed, 11 insertions(+)

diff --git a/regression-test/suites/correctness_p0/test_current_timestamp.groovy b/regression-test/suites/correctness_p0/test_current_timestamp.groovy
index 8aca63fc06e595..209ce465e4f385 100644
--- 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/regression-test/suites/query_p0/sql_functions/aggregate_functions/test_aggregate_all_functions.groovy b/regression-test/suites/query_p0/sql_functions/aggregate_functions/test_aggregate_all_functions.groovy
index 973ea22dffa9b8..dbc6a998a5cb91 100644
--- a/regression-test/suites/query_p0/sql_functions/aggregate_functions/test_aggregate_all_functions.groovy
+++ b/regression-test/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"""