From 7890e464eed7de253b54286016b266b4e4e69ff4 Mon Sep 17 00:00:00 2001 From: Dongyang Li Date: Wed, 9 Aug 2023 11:03:31 +0800 Subject: [PATCH] [fix](case) 1. disable unstable case window_function 2. add sync after stream load (#22677) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit * Update test_dup_tab_auto_inc_with_null.groovy，add sync after streamload * Update test_unique_table_auto_inc.groovy, add sync after streamload* [fix](case) disable unstable case window_function --- .../pipeline/p0/conf/regression-conf.groovy | 2 +- .../storage/test_dup_tab_auto_inc_with_null.groovy | 3 +++ .../unique/test_unique_table_auto_inc.groovy | 10 ++++++++++ 3 files changed, 14 insertions(+), 1 deletion(-) diff --git a/regression-test/pipeline/p0/conf/regression-conf.groovy b/regression-test/pipeline/p0/conf/regression-conf.groovy index 86fc3ba38b..fc9c69fcf0 100644 --- a/regression-test/pipeline/p0/conf/regression-conf.groovy +++ b/regression-test/pipeline/p0/conf/regression-conf.groovy @@ -54,7 +54,7 @@ testDirectories = "" // this groups will not be executed excludeGroups = "" // this suites will not be executed -excludeSuites = "test_profile,test_broker_load,test_spark_load,test_analyze_stats_p1,test_refresh_mtmv,test_bitmap_filter,test_export_parquet,test_doris_jdbc_catalog" +excludeSuites = "window_function,test_profile,test_broker_load,test_spark_load,test_analyze_stats_p1,test_refresh_mtmv,test_bitmap_filter,test_export_parquet,test_doris_jdbc_catalog" // this directories will not be executed excludeDirectories = "workload_manager_p1" diff --git a/regression-test/suites/data_model_p0/duplicate/storage/test_dup_tab_auto_inc_with_null.groovy b/regression-test/suites/data_model_p0/duplicate/storage/test_dup_tab_auto_inc_with_null.groovy index f56b212109..f6e177c0f2 100644 --- a/regression-test/suites/data_model_p0/duplicate/storage/test_dup_tab_auto_inc_with_null.groovy +++ b/regression-test/suites/data_model_p0/duplicate/storage/test_dup_tab_auto_inc_with_null.groovy @@ -78,6 +78,7 @@ suite("test_dup_table_auto_inc_basic_with_null") { file 'auto_inc_basic_with_null_2.csv' time 10000 // limit inflight 10s } + sql """sync""" qt_auto_inc_ids "select * from ${table2};" sql "drop table if exists ${table2};" @@ -110,6 +111,7 @@ suite("test_dup_table_auto_inc_basic_with_null") { file 'auto_inc_basic_with_null.csv' time 10000 // limit inflight 10s } + sql """sync""" qt_auto_inc_ids "select * from ${table3} order by id;" sql "drop table if exists ${table3};" @@ -142,6 +144,7 @@ suite("test_dup_table_auto_inc_basic_with_null") { file 'auto_inc_basic_with_null_2.csv' time 10000 // limit inflight 10s } + sql """sync""" qt_auto_inc_ids "select * from ${table4} order by id;" sql "drop table if exists ${table4};" diff --git a/regression-test/suites/data_model_p0/unique/test_unique_table_auto_inc.groovy b/regression-test/suites/data_model_p0/unique/test_unique_table_auto_inc.groovy index cdfac6d00c..a277114f1b 100644 --- a/regression-test/suites/data_model_p0/unique/test_unique_table_auto_inc.groovy +++ b/regression-test/suites/data_model_p0/unique/test_unique_table_auto_inc.groovy @@ -46,6 +46,7 @@ suite("test_unique_table_auto_inc") { file 'auto_inc_basic.csv' time 10000 // limit inflight 10s } + sql "sync" qt_sql "select * from ${table1};" sql """ insert into ${table1} values(0, "Bob", 123), (2, "Tom", 323), (4, "Carter", 523);""" qt_sql "select * from ${table1} order by id" @@ -80,6 +81,7 @@ suite("test_unique_table_auto_inc") { file 'auto_inc_basic.csv' time 10000 // limit inflight 10s } + sql "sync" qt_sql "select id, name, value from ${table2} order by id;" sql """ insert into ${table2} values("Bob", 100, 1230), ("Tom", 300, 1232), ("Carter", 500, 1234);""" qt_sql "select id, name, value from ${table2} order by id;" @@ -114,6 +116,7 @@ suite("test_unique_table_auto_inc") { file 'auto_inc_with_null.csv' time 10000 // limit inflight 10s } + sql "sync" qt_sql "select * from ${table3};" sql """ insert into ${table3} values(0, "Bob", 123), (2, "Tom", 323), (4, "Carter", 523);""" qt_sql "select * from ${table3} order by id" @@ -148,6 +151,7 @@ suite("test_unique_table_auto_inc") { file 'auto_inc_update_inplace.csv' time 10000 // limit inflight 10s } + sql "sync" qt_update_inplace "select * from ${table4};" sql "drop table if exists ${table4};" @@ -180,6 +184,7 @@ suite("test_unique_table_auto_inc") { file 'auto_inc_basic.csv' time 10000 // limit inflight 10s } + sql "sync" qt_partial_update_key "select * from ${table5} order by id;" streamLoad { @@ -193,6 +198,7 @@ suite("test_unique_table_auto_inc") { file 'auto_inc_partial_update1.csv' time 10000 } + sql "sync" qt_partial_update_key "select * from ${table5} order by id;" sql "drop table if exists ${table5};" @@ -225,6 +231,7 @@ suite("test_unique_table_auto_inc") { file 'auto_inc_basic.csv' time 10000 // limit inflight 10s } + sql "sync" qt_partial_update_value "select * from ${table6} order by id;" streamLoad { @@ -238,6 +245,7 @@ suite("test_unique_table_auto_inc") { file 'auto_inc_partial_update2.csv' time 10000 } + sql "sync" qt_partial_update_value "select * from ${table6} order by id;" sql "drop table if exists ${table6};" @@ -270,6 +278,7 @@ suite("test_unique_table_auto_inc") { file 'auto_inc_basic.csv' time 10000 // limit inflight 10s } + sql "sync" qt_partial_update_value "select * from ${table7} order by id;" streamLoad { @@ -283,6 +292,7 @@ suite("test_unique_table_auto_inc") { file 'auto_inc_partial_update2.csv' time 10000 } + sql "sync" qt_partial_update_value "select * from ${table7} order by id;" sql "drop table if exists ${table7};" }