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 a1e9e7b1184 [fix](case) fix group commit case (#53292)
a1e9e7b1184 is described below
commit a1e9e7b1184b8f16bd0139937fe91cd5474a5a94
Author: meiyi <[email protected]>
AuthorDate: Thu Jul 17 12:09:55 2025 +0800
[fix](case) fix group commit case (#53292)
---
be/src/runtime/group_commit_mgr.cpp | 15 +++++++++------
...test_group_commit_async_wal_msg_fault_injection.groovy | 4 ++--
2 files changed, 11 insertions(+), 8 deletions(-)
diff --git a/be/src/runtime/group_commit_mgr.cpp
b/be/src/runtime/group_commit_mgr.cpp
index bb0d626bab3..fa1a22296c4 100644
--- a/be/src/runtime/group_commit_mgr.cpp
+++ b/be/src/runtime/group_commit_mgr.cpp
@@ -432,13 +432,15 @@ Status
GroupCommitTable::_finish_group_commit_load(int64_t db_id, int64_t table_
RuntimeState* state) {
Status st;
Status result_status;
- DBUG_EXECUTE_IF("LoadBlockQueue._finish_group_commit_load.err_status",
- { status = Status::InternalError(""); });
+ DBUG_EXECUTE_IF("LoadBlockQueue._finish_group_commit_load.err_status", {
+ status =
Status::InternalError("LoadBlockQueue._finish_group_commit_load.err_status");
+ });
DBUG_EXECUTE_IF("LoadBlockQueue._finish_group_commit_load.load_error",
{ status = Status::InternalError("load_error"); });
if (status.ok()) {
-
DBUG_EXECUTE_IF("LoadBlockQueue._finish_group_commit_load.commit_error",
- { status = Status::InternalError(""); });
+
DBUG_EXECUTE_IF("LoadBlockQueue._finish_group_commit_load.commit_error", {
+ status =
Status::InternalError("LoadBlockQueue._finish_group_commit_load.commit_error");
+ });
// commit txn
TLoadTxnCommitRequest request;
// deprecated and should be removed in 3.1, use token instead
@@ -531,8 +533,9 @@ Status GroupCommitTable::_finish_group_commit_load(int64_t
db_id, int64_t table_
// status: exec_plan_fragment result
// st: commit txn rpc status
// result_status: commit txn result
- DBUG_EXECUTE_IF("LoadBlockQueue._finish_group_commit_load.err_st",
- { st = Status::InternalError(""); });
+ DBUG_EXECUTE_IF("LoadBlockQueue._finish_group_commit_load.err_st", {
+ st =
Status::InternalError("LoadBlockQueue._finish_group_commit_load.err_st");
+ });
if (status.ok() && st.ok() &&
(result_status.ok() ||
result_status.is<ErrorCode::PUBLISH_TIMEOUT>())) {
if (!config::group_commit_wait_replay_wal_finish) {
diff --git
a/regression-test/suites/fault_injection_p0/test_group_commit_async_wal_msg_fault_injection.groovy
b/regression-test/suites/fault_injection_p0/test_group_commit_async_wal_msg_fault_injection.groovy
index 2d0b91a01ed..0f572986bdc 100644
---
a/regression-test/suites/fault_injection_p0/test_group_commit_async_wal_msg_fault_injection.groovy
+++
b/regression-test/suites/fault_injection_p0/test_group_commit_async_wal_msg_fault_injection.groovy
@@ -156,7 +156,7 @@
suite("test_group_commit_async_wal_msg_fault_injection","nonConcurrent") {
) engine=olap
DISTRIBUTED BY HASH(`k`)
BUCKETS 5
- properties("replication_num" = "1", "group_commit_interval_ms" =
"4000")
+ properties("replication_num" = "1", "group_commit_interval_ms" =
"10000")
"""
GetDebugPoint().clearDebugPointsForAllBEs()
try {
@@ -167,7 +167,7 @@
suite("test_group_commit_async_wal_msg_fault_injection","nonConcurrent") {
set 'group_commit', 'async_mode'
unset 'label'
file 'group_commit_wal_msg.csv'
- time 10000
+ time 6000
}
getRowCount(5)
} finally {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
