This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 0dd2fb758c [fix](test) add sync and drop table for insert.groovy and
test_array_load.groovy (#13105)
0dd2fb758c is described below
commit 0dd2fb758cc777284b4506d8ceaa51fc4603a5cf
Author: Yongqiang YANG <98214048+dataroar...@users.noreply.github.com>
AuthorDate: Tue Oct 4 10:24:38 2022 +0800
[fix](test) add sync and drop table for insert.groovy and
test_array_load.groovy (#13105)
We need sync for multi fe env.
---
regression-test/suites/insert_p0/insert.groovy | 3 ++-
regression-test/suites/load_p0/broker_load/test_array_load.groovy | 6 ++++++
regression-test/suites/tpcds_sf1_unique_p1/load.groovy | 1 +
3 files changed, 9 insertions(+), 1 deletion(-)
diff --git a/regression-test/suites/insert_p0/insert.groovy
b/regression-test/suites/insert_p0/insert.groovy
index 27688f7971..2c1d8bd9a1 100644
--- a/regression-test/suites/insert_p0/insert.groovy
+++ b/regression-test/suites/insert_p0/insert.groovy
@@ -80,6 +80,7 @@ suite("insert") {
sql """ insert into mutable_datatype values(1, cast(2.1 as double), 'abc',
cast('2014-01-01' as date), cast('2015-01-01 03:15:16' as datetime), FALSE,
'-123.22', '-123456789012345678.012345678') """
sql """ insert into mutable_datatype values(5 * 10, cast(4.1 + 5 as
double), 'abc', cast('2014-01-01' as date), cast('2015-01-01 03:15:16' as
datetime), TRUE, '123.22', '123456789012345678.012345678') """
+ sql "sync"
qt_insert """ select * from mutable_datatype """
-}
\ No newline at end of file
+}
diff --git a/regression-test/suites/load_p0/broker_load/test_array_load.groovy
b/regression-test/suites/load_p0/broker_load/test_array_load.groovy
index b71722b425..ec81eeea0c 100644
--- a/regression-test/suites/load_p0/broker_load/test_array_load.groovy
+++ b/regression-test/suites/load_p0/broker_load/test_array_load.groovy
@@ -187,6 +187,7 @@ suite("test_array_load", "p0") {
while(max_try_milli_secs) {
result = sql "show load where label = '${checklabel}'"
if(result[0][2] == "FINISHED") {
+ sql "sync"
qt_select "select * from ${testTablex} order by k1"
break
} else {
@@ -208,6 +209,7 @@ suite("test_array_load", "p0") {
load_array_data.call(testTable, 'true', '', 'json', '', '', '', '',
'', '', 'simple_array.json')
// select the table and check whether the data is correct
+ sql "sync"
qt_select "select * from ${testTable} order by k1"
} finally {
@@ -223,6 +225,7 @@ suite("test_array_load", "p0") {
load_array_data.call(testTable, 'true', '', 'json', '', '', '', '',
'', '', 'simple_array.json')
// select the table and check whether the data is correct
+ sql "sync"
qt_select "select * from ${testTable} order by k1"
} finally {
@@ -238,6 +241,7 @@ suite("test_array_load", "p0") {
load_array_data.call(testTable, 'true', '', 'csv', '', '', '', '', '',
'/', 'simple_array.csv')
// select the table and check whether the data is correct
+ sql "sync"
qt_select "select * from ${testTable} order by k1"
} finally {
@@ -253,6 +257,7 @@ suite("test_array_load", "p0") {
load_array_data.call(testTable, 'true', '', 'csv', '', '', '', '', '',
'/', 'simple_array.csv')
// select the table and check whether the data is correct
+ sql "sync"
qt_select "select * from ${testTable} order by k1"
} finally {
@@ -268,6 +273,7 @@ suite("test_array_load", "p0") {
load_array_data.call(testTable01, '', '', '', '', '', '', '', '', '/',
'simple_array.data')
// select the table and check whether the data is correct
+ sql "sync"
qt_select "select * from ${testTable01} order by k1"
} finally {
diff --git a/regression-test/suites/tpcds_sf1_unique_p1/load.groovy
b/regression-test/suites/tpcds_sf1_unique_p1/load.groovy
index 167c0c08e8..d8bf712330 100644
--- a/regression-test/suites/tpcds_sf1_unique_p1/load.groovy
+++ b/regression-test/suites/tpcds_sf1_unique_p1/load.groovy
@@ -144,6 +144,7 @@ suite("load") {
def origin_count = sql "select count(*) from item"
def new_count = sql "select count(*) from t"
assertEquals(origin_count, new_count)
+ sql "drop table if exists tt;"
sql "create table tt like item"
sql "insert into tt select * from t"
new_count = sql "select count(*) from tt"
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
