database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](group commit) fix repaly wal check label status (#38883) (#38997)

Browse Source 
pick https://github.com/apache/doris/pull/38883
This commit is contained in:
meiyi
2024-08-07 22:06:59 +08:00
committed by GitHub
parent 773008d6fa
commit 749c9f7b56
7 changed files with 197 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
be/src/runtime/group_commit_mgr.cpp
View File

@ -397,6 +397,8 @@ Status GroupCommitTable::_finish_group_commit_load(int64_t db_id, int64_t table_
Status result_status;
DBUG_EXECUTE_IF("LoadBlockQueue._finish_group_commit_load.err_status",
{ status = Status::InternalError(""); });
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(""); });
@ -425,6 +427,8 @@ Status GroupCommitTable::_finish_group_commit_load(int64_t db_id, int64_t table_
},
10000L);
result_status = Status::create(result.status);
DBUG_EXECUTE_IF("LoadBlockQueue._finish_group_commit_load.commit_success_and_rpc_error",
{ result_status = Status::InternalError("commit_success_and_rpc_error"); });
} else {
// abort txn
TLoadTxnRollbackRequest request;