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

[fix](group commit) Fix test_group_commit_async_wal_msg_fault_injection case (#35313) (#38911)

Browse Source 
pick https://github.com/apache/doris/pull/35313
This commit is contained in:
meiyi
2024-08-06 17:57:22 +08:00
committed by GitHub
parent fe6ea3b8b5
commit 3abb222064
3 changed files with 27 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -505,10 +505,12 @@ Status GroupCommitTable::_finish_group_commit_load(int64_t db_id, int64_t table_
}
LOG(INFO) << ss.str();
DBUG_EXECUTE_IF("LoadBlockQueue._finish_group_commit_load.get_wal_back_pressure_msg", {
std ::string msg = _exec_env->wal_mgr()->get_wal_dirs_info_string();
LOG(INFO) << "debug promise set: " << msg;
ExecEnv::GetInstance()->group_commit_mgr()->debug_promise.set_value(
Status ::InternalError(msg));
if (dp->param<int64_t>("table_id", -1) == table_id) {
std ::string msg = _exec_env->wal_mgr()->get_wal_dirs_info_string();
LOG(INFO) << "table_id" << std::to_string(table_id) << " set debug promise: " << msg;
ExecEnv::GetInstance()->group_commit_mgr()->debug_promise.set_value(
Status ::InternalError(msg));
}
};);
return st;
}