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 b4df998c393 branch-2.1: [fix](case) fix some group commit case (#53295)
b4df998c393 is described below
commit b4df998c3931931d97a181b38f341933fd9a9d61
Author: meiyi <[email protected]>
AuthorDate: Mon Jul 21 16:51:32 2025 +0800
branch-2.1: [fix](case) fix some group commit case (#53295)
---
.../suites/insert_p0/insert_group_commit_with_exception.groovy | 2 +-
.../suites/insert_p0/test_group_commit_interval_ms_property.groovy | 4 +++-
2 files changed, 4 insertions(+), 2 deletions(-)
diff --git
a/regression-test/suites/insert_p0/insert_group_commit_with_exception.groovy
b/regression-test/suites/insert_p0/insert_group_commit_with_exception.groovy
index 421ef1695ad..4d44fe82353 100644
--- a/regression-test/suites/insert_p0/insert_group_commit_with_exception.groovy
+++ b/regression-test/suites/insert_p0/insert_group_commit_with_exception.groovy
@@ -157,7 +157,7 @@ suite("insert_group_commit_with_exception",
"nonConcurrent") {
try (Connection connection = DriverManager.getConnection(url,
context.config.jdbcUser, context.config.jdbcPassword)) {
Statement statement = connection.createStatement();
statement.execute("use ${db}");
- statement.execute("set group_commit = eventual_consistency;");
+ statement.execute("set group_commit = async_mode;");
if (item == "nereids") {
statement.execute("set enable_nereids_dml = true;");
statement.execute("set enable_nereids_planner=true;");
diff --git
a/regression-test/suites/insert_p0/test_group_commit_interval_ms_property.groovy
b/regression-test/suites/insert_p0/test_group_commit_interval_ms_property.groovy
index 980e38e5350..4debe830140 100644
---
a/regression-test/suites/insert_p0/test_group_commit_interval_ms_property.groovy
+++
b/regression-test/suites/insert_p0/test_group_commit_interval_ms_property.groovy
@@ -75,12 +75,14 @@ suite("test_group_commit_interval_ms_property") {
def msg1 = group_commit_insert """insert into ${test_table}
values(1,1); """, 1
- Thread.sleep(8000);
+ Thread.sleep(4000);
def msg2 = group_commit_insert """insert into ${test_table}
values(2,2) """, 1
assertEquals(msg1.substring(msg1.indexOf("group_commit")+11,
msg1.indexOf("group_commit")+43),
msg2.substring(msg2.indexOf("group_commit")+11,
msg2.indexOf("group_commit")+43));
+ Thread.sleep(8000);
+
sql "ALTER table ${test_table} SET
(\"group_commit_interval_ms\"=\"1000\"); "
def res2 = sql """show create table ${test_table}"""
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
