You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by da...@apache.org on 2022/10/04 02:24:45 UTC

[doris] branch master updated: [fix](test) add sync and drop table for insert.groovy and test_array_load.groovy (#13105)

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 <98...@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-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org