[improvement](hashjoin) support partitioned hash table in hash join (#14480)

2022-11-24 14:16:47 +08:00
parent e656dae3f0
commit 6c7f758ef7
9 changed files with 795 additions and 76 deletions
--- a/be/src/vec/runtime/shared_hash_table_controller.cpp
+++ b/be/src/vec/runtime/shared_hash_table_controller.cpp
@ -121,10 +121,10 @@ Status SharedHashTableController::release_ref_count_if_need(TUniqueId fragment_i

 Status SharedHashTableController::wait_for_closable(RuntimeState* state, int my_node_id) {
    std::unique_lock<std::mutex> lock(_mutex);
-    RETURN_IF_CANCELLED(state);
    if (!_ref_fragments[my_node_id].empty()) {
        _cv.wait(lock, [&]() { return _ref_fragments[my_node_id].empty(); });
    }
+    RETURN_IF_CANCELLED(state);
    return Status::OK();
 }