You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by mo...@apache.org on 2023/04/23 16:20:34 UTC
[doris] 01/08: [chore](regression) Add 'sync' after stream_load in some cases (#18945)
This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-2.0-alpha
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 76d4240a2ab2e41caf9230099ed0782e8f49ecfb
Author: Jerry Hu <mr...@gmail.com>
AuthorDate: Sun Apr 23 14:39:33 2023 +0800
[chore](regression) Add 'sync' after stream_load in some cases (#18945)
---
.../suites/correctness_p0/test_current_timestamp.groovy | 9 +++++++++
.../aggregate_functions/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 8aca63fc06..209ce465e4 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 973ea22dff..dbc6a998a5 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"""
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org