This is an automated email from the ASF dual-hosted git repository. kxiao pushed a commit to branch branch-2.0 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 7db37920c1a969bb27b2ae1a5b482fe5607d8dc7 Author: TengJianPing <[email protected]> AuthorDate: Tue Aug 29 15:29:51 2023 +0800 [fix](regression) add sync for loading data to avoid case failure in multi-fe test env (#23604) --- regression-test/suites/query_p0/join/test_partitioned_hash_join.groovy | 3 +++ regression-test/suites/ssb_sf0.1_p1/load.groovy | 1 + regression-test/suites/ssb_unique_sql_zstd_p0/load.groovy | 2 ++ regression-test/suites/tpcds_sf1_p1/load.groovy | 1 + regression-test/suites/tpcds_sf1_p2/load.groovy | 1 + regression-test/suites/tpcds_sf1_unique_p1/load.groovy | 2 ++ regression-test/suites/tpch_sf0.1_p1/load.groovy | 1 + regression-test/suites/tpch_sf0.1_unique_p1/load.groovy | 2 ++ regression-test/suites/tpch_sf1_p2/load.groovy | 2 ++ regression-test/suites/tpch_sf1_unique_p2/load.groovy | 1 + regression-test/suites/tpch_unique_sql_zstd_p0/load.groovy | 2 ++ 11 files changed, 18 insertions(+) diff --git a/regression-test/suites/query_p0/join/test_partitioned_hash_join.groovy b/regression-test/suites/query_p0/join/test_partitioned_hash_join.groovy index bad3af4c69..cbe09ec527 100644 --- a/regression-test/suites/query_p0/join/test_partitioned_hash_join.groovy +++ b/regression-test/suites/query_p0/join/test_partitioned_hash_join.groovy @@ -58,8 +58,11 @@ suite("test_partitioned_hash_join", "query,p0") { assertTrue(json.NumberLoadedRows > 0 && json.LoadBytes > 0) } } + sql """ set enable_profile = 1; """ sql "insert into test_partitioned_hash_join_l values (100, 1100), (0, 10), (1, 110), (255, 2550)"; + sql """ sync """ + qt_partitioned_hash_join1 """ select /*+SET_VAR(disable_join_reorder=true,experimental_enable_pipeline_engine=false, parallel_fragment_exec_instance_num=1, partitioned_hash_join_rows_threshold = 1)*/ diff --git a/regression-test/suites/ssb_sf0.1_p1/load.groovy b/regression-test/suites/ssb_sf0.1_p1/load.groovy index 5151bff68e..3b3955dc3a 100644 --- a/regression-test/suites/ssb_sf0.1_p1/load.groovy +++ b/regression-test/suites/ssb_sf0.1_p1/load.groovy @@ -119,4 +119,5 @@ suite("load") { rowCount = sql "select count(*) from ${table}" assertEquals(table_rows, rowCount[0][0]) } + sql """ sync """ } diff --git a/regression-test/suites/ssb_unique_sql_zstd_p0/load.groovy b/regression-test/suites/ssb_unique_sql_zstd_p0/load.groovy index 1c51fdd56e..5e0a460569 100644 --- a/regression-test/suites/ssb_unique_sql_zstd_p0/load.groovy +++ b/regression-test/suites/ssb_unique_sql_zstd_p0/load.groovy @@ -77,4 +77,6 @@ suite("load") { } i++ } + + sql """ sync """ } diff --git a/regression-test/suites/tpcds_sf1_p1/load.groovy b/regression-test/suites/tpcds_sf1_p1/load.groovy index d44fd13e11..5e1422b58d 100644 --- a/regression-test/suites/tpcds_sf1_p1/load.groovy +++ b/regression-test/suites/tpcds_sf1_p1/load.groovy @@ -100,4 +100,5 @@ suite("load") { } sql """ ANALYZE TABLE $tableName WITH SYNC """ } + sql """ sync """ } diff --git a/regression-test/suites/tpcds_sf1_p2/load.groovy b/regression-test/suites/tpcds_sf1_p2/load.groovy index e8275d0fb4..5df694c6b4 100644 --- a/regression-test/suites/tpcds_sf1_p2/load.groovy +++ b/regression-test/suites/tpcds_sf1_p2/load.groovy @@ -69,4 +69,5 @@ suite("load") { } sql """ ANALYZE TABLE $tableName WITH SYNC """ } + sql """ sync """ } diff --git a/regression-test/suites/tpcds_sf1_unique_p1/load.groovy b/regression-test/suites/tpcds_sf1_unique_p1/load.groovy index bfe7b9fd31..9f7f7d198c 100644 --- a/regression-test/suites/tpcds_sf1_unique_p1/load.groovy +++ b/regression-test/suites/tpcds_sf1_unique_p1/load.groovy @@ -152,4 +152,6 @@ suite("load") { sql "insert into tt select * from t" new_count = sql "select count(*) from tt" assertEquals(origin_count, new_count) + + sql """ sync """ } diff --git a/regression-test/suites/tpch_sf0.1_p1/load.groovy b/regression-test/suites/tpch_sf0.1_p1/load.groovy index 9b8d54a4da..3e538056d7 100644 --- a/regression-test/suites/tpch_sf0.1_p1/load.groovy +++ b/regression-test/suites/tpch_sf0.1_p1/load.groovy @@ -78,4 +78,5 @@ suite("load") { def table = "revenue1" sql new File("""${context.file.parent}/ddl/${table}_delete.sql""").text sql new File("""${context.file.parent}/ddl/${table}.sql""").text + sql """ sync """ } diff --git a/regression-test/suites/tpch_sf0.1_unique_p1/load.groovy b/regression-test/suites/tpch_sf0.1_unique_p1/load.groovy index 6bc41d49f9..9e9d511e26 100644 --- a/regression-test/suites/tpch_sf0.1_unique_p1/load.groovy +++ b/regression-test/suites/tpch_sf0.1_unique_p1/load.groovy @@ -80,4 +80,6 @@ suite("load") { def table = "revenue1" sql new File("""${context.file.parent}/ddl/${table}_delete.sql""").text sql new File("""${context.file.parent}/ddl/${table}.sql""").text + + sql """ sync """ } diff --git a/regression-test/suites/tpch_sf1_p2/load.groovy b/regression-test/suites/tpch_sf1_p2/load.groovy index db5e5dc775..c7136d265d 100644 --- a/regression-test/suites/tpch_sf1_p2/load.groovy +++ b/regression-test/suites/tpch_sf1_p2/load.groovy @@ -118,4 +118,6 @@ suite("load") { // We need wait to make sure BE could pass the stats info to FE so that // avoid unnessary inconsistent generated plan which would cause the regression test fail sleep(60000) + + sql """ sync """ } diff --git a/regression-test/suites/tpch_sf1_unique_p2/load.groovy b/regression-test/suites/tpch_sf1_unique_p2/load.groovy index 26e7267125..cccc988ae9 100644 --- a/regression-test/suites/tpch_sf1_unique_p2/load.groovy +++ b/regression-test/suites/tpch_sf1_unique_p2/load.groovy @@ -103,4 +103,5 @@ suite("load") { def table = "revenue1" sql new File("""${context.file.parent}/ddl/${table}_delete.sql""").text sql new File("""${context.file.parent}/ddl/${table}.sql""").text + sql """ sync """ } diff --git a/regression-test/suites/tpch_unique_sql_zstd_p0/load.groovy b/regression-test/suites/tpch_unique_sql_zstd_p0/load.groovy index 885330c616..444c7d413e 100644 --- a/regression-test/suites/tpch_unique_sql_zstd_p0/load.groovy +++ b/regression-test/suites/tpch_unique_sql_zstd_p0/load.groovy @@ -79,4 +79,6 @@ suite("load") { def table = "revenue1" sql new File("""${context.file.parent}/ddl/${table}_delete.sql""").text sql new File("""${context.file.parent}/ddl/${table}.sql""").text + + sql """ sync """ } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
