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

[fix](shared hash table) fix p0 test failure (#23907)

Browse Source
This commit is contained in:
Gabriel
2023-09-05 14:48:46 +08:00
committed by GitHub
parent 801ddc0313
commit 1a8913f8f4
1 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
be/src/vec/runtime/shared_hash_table_controller.cpp
View File

@ -38,12 +38,17 @@ bool SharedHashTableController::should_build_hash_table(const TUniqueId& fragmen
int my_node_id) {
std::lock_guard<std::mutex> lock(_mutex);
auto it = _builder_fragment_ids.find(my_node_id);
DCHECK(_pipeline_engine_enabled && it != _builder_fragment_ids.cend());
if (it != _builder_fragment_ids.cend()) {
return it->second == fragment_instance_id;
if (_pipeline_engine_enabled) {
if (it != _builder_fragment_ids.cend()) {
return it->second == fragment_instance_id;
}
return false;
}
if (it == _builder_fragment_ids.cend()) {
_builder_fragment_ids.insert({my_node_id, fragment_instance_id});
return true;
}
throw Exception(ErrorCode::INTERNAL_ERROR,
"Shared hash table for node {} has not been initialized!", my_node_id);
return false;
}