This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 5f40c79ae30 [Fix](cloud) fix test_stream_load_2pc regression test for
that mow table doesn't support 2pc in cloud mode (#38386)
5f40c79ae30 is described below
commit 5f40c79ae30f49f77e0145ebd12f615087388459
Author: Xin Liao <[email protected]>
AuthorDate: Fri Jul 26 10:16:41 2024 +0800
[Fix](cloud) fix test_stream_load_2pc regression test for that mow table
doesn't support 2pc in cloud mode (#38386)
---
.../load_p0/http_stream/test_cloud_http_stream_2pc_mow.groovy | 2 +-
.../suites/load_p0/stream_load/test_stream_load_2pc.groovy | 7 ++++++-
2 files changed, 7 insertions(+), 2 deletions(-)
diff --git
a/regression-test/suites/load_p0/http_stream/test_cloud_http_stream_2pc_mow.groovy
b/regression-test/suites/load_p0/http_stream/test_cloud_http_stream_2pc_mow.groovy
index eebc61ab176..292c1ab2d9f 100644
---
a/regression-test/suites/load_p0/http_stream/test_cloud_http_stream_2pc_mow.groovy
+++
b/regression-test/suites/load_p0/http_stream/test_cloud_http_stream_2pc_mow.groovy
@@ -50,7 +50,7 @@ suite("test_cloud_http_stream_2pc_mow", "p0") {
set 'version', '1'
set 'two_phase_commit', 'true'
set 'sql', """
- insert into ${db}.${tableName1} select * from
http_stream("column_separator"=",", "format"="csv")
+ insert into ${db}.${tableName} select * from
http_stream("column_separator"=",", "format"="csv")
"""
time 10000
file 'all_types.csv'
diff --git
a/regression-test/suites/load_p0/stream_load/test_stream_load_2pc.groovy
b/regression-test/suites/load_p0/stream_load/test_stream_load_2pc.groovy
index 3295b787715..99a6be4d5cb 100644
--- a/regression-test/suites/load_p0/stream_load/test_stream_load_2pc.groovy
+++ b/regression-test/suites/load_p0/stream_load/test_stream_load_2pc.groovy
@@ -301,7 +301,8 @@ suite("test_stream_load_2pc", "p0") {
""",
"""
- "replication_num" = "1"
+ "replication_num" = "1",
+ "enable_unique_key_merge_on_write" = "false"
""",
"""
@@ -565,6 +566,10 @@ suite("test_stream_load_2pc", "p0") {
def expected = [1, 3, 3, 5, 21]
// we recreate table for each partition, then load data with stream
load and check the result
for (i = 0; i < tables.size(); ++i) {
+ if (isCloudMode() && tables[i] == "stream_load_mow_tbl_basic") {
+ log.info("Skip stream load mow table in cloud mode")
+ continue;
+ }
def j = 0
for (String paritition in tbl_partitions) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
