[fix](case) 1. disable unstable case window_function 2. add sync after stream load (#22677)

* 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
This commit is contained in:
Dongyang Li
2023-08-09 11:03:31 +08:00
committed by GitHub
parent 4608dcb2d9
commit 7890e464ee
3 changed files with 14 additions and 1 deletions

View File

@ -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"

View File

@ -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};"

View File

@ -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};"
}