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

[fix](group commit) Pick Fix the incorrect group commit count in log; fix the core in get_first_block (#36408) (#37405)

Browse Source 
Pick https://github.com/apache/doris/pull/36408/
This commit is contained in:
meiyi
2024-07-09 09:24:43 +08:00
committed by GitHub
parent a6ec78ec5f
commit 1a25270918
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -199,6 +199,7 @@ Status LoadBlockQueue::add_load_id(const UniqueId& load_id) {
load_instance_id.to_string());
}
_load_ids.emplace(load_id);
group_commit_load_count.fetch_add(1);
return Status::OK();
}
@ -265,7 +266,7 @@ Status GroupCommitTable::get_first_block_load_queue(
}
if (!_is_creating_plan_fragment) {
_is_creating_plan_fragment = true;
RETURN_IF_ERROR(_thread_pool->submit_func([&] {
RETURN_IF_ERROR(_thread_pool->submit_func([this, be_exe_version, mem_tracker] {
auto st = _create_group_commit_load(be_exe_version, mem_tracker);
if (!st.ok()) {
LOG(WARNING) << "create group commit load error, st=" << st.to_string();