This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 6a6c0257dc0 branch-3.0: [fix](case) fix regression case
create_commit_mtmv_many_tasks #53247 (#53303)
6a6c0257dc0 is described below
commit 6a6c0257dc006d009a96838b944e99af88c6910d
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Jul 15 19:33:05 2025 +0800
branch-3.0: [fix](case) fix regression case create_commit_mtmv_many_tasks
#53247 (#53303)
Cherry-picked from #53247
Co-authored-by: zhangdong <[email protected]>
---
.../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: [email protected]
For additional commands, e-mail: [email protected]
