This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new fb73066ca01 branch-2.1: [fix](case) fix regression case
create_commit_mtmv_many_tasks #53247 (#53304)
fb73066ca01 is described below
commit fb73066ca01d81c6caf1e66903704a7e18adfcc8
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Sat Jul 26 23:51:15 2025 +0800
branch-2.1: [fix](case) fix regression case create_commit_mtmv_many_tasks
#53247 (#53304)
Cherry-picked from #53247
Co-authored-by: zhangdong <zhangd...@selectdb.com>
---
.../mv/create_part_and_up/create_commit_mtmv_many_task.groovy | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/regression-test/suites/nereids_rules_p0/mv/create_part_and_up/create_commit_mtmv_many_task.groovy
b/regression-test/suites/nereids_rules_p0/mv/create_part_and_up/create_commit_mtmv_many_task.groovy
index ec5054f9190..db4acfafee1 100644
---
a/regression-test/suites/nereids_rules_p0/mv/create_part_and_up/create_commit_mtmv_many_task.groovy
+++
b/regression-test/suites/nereids_rules_p0/mv/create_part_and_up/create_commit_mtmv_many_task.groovy
@@ -95,7 +95,7 @@ suite("create_commit_mtmv_many_tasks", "p2") {
sql "select count(*) from ${table_name}"
}
- for (int i = 1; i <= 10; i++) {
+ for (int i = 1; i <= 1; i++) {
stream_load_job(table_name1, "lineitem.tbl.${i}")
stream_load_job(table_name2, "orders.tbl.${i}")
}
@@ -163,11 +163,11 @@ suite("create_commit_mtmv_many_tasks", "p2") {
def insert_into_select = { date_it ->
sql """INSERT INTO ${dst_database_name}.${table_name1}
SELECT l_orderkey, l_linenumber, l_partkey, l_suppkey, l_quantity,
l_extendedprice, l_discount, l_tax, l_returnflag, l_linestatus, l_commitdate,
l_receiptdate, l_shipinstruct, l_shipmode, l_comment, '${date_it}' AS
new_date_column
- FROM ${src_database_name}.${table_name1};"""
+ FROM ${src_database_name}.${table_name1} limit 1;"""
sql """INSERT INTO ${dst_database_name}.${table_name2}
SELECT o_orderkey, o_custkey, o_orderstatus, o_totalprice,
o_orderpriority, o_clerk, o_shippriority, o_comment, '${date_it}' AS
new_date_column
- FROM ${src_database_name}.${table_name2}"""
+ FROM ${src_database_name}.${table_name2} limit 1"""
}
def get_next_day = { def date_it ->
@@ -189,7 +189,7 @@ suite("create_commit_mtmv_many_tasks", "p2") {
def job_name = getJobName(dst_database_name, "mv1")
waitingMTMVTaskFinished(job_name)
def task_num = sql """select count(*) from tasks("type"="mv") where
JobName="${job_name}";"""
- assertTrue(task_num[0][0] < 100)
+ assertTrue(task_num[0][0] < 200)
def mv_row_count = sql """select count(1) from mv1;"""
def real_row_count = sql """select count(1) from (select l_shipdate,
l_orderkey from lineitem as t1 left join orders as t2 on t1.l_orderkey =
t2.o_orderkey group by l_shipdate, l_orderkey) t;"""
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
