[pipelineX](dependency) refactor write dependency (#24555)

be/src/vec/runtime/shared_hash_table_controller.cpp

@@ -23,6 +23,8 @@
 #include <chrono> // IWYU pragma: keep
 #include <utility>
 
+#include "pipeline/exec/hashjoin_build_sink.h"
+
 namespace doris {
 namespace vectorized {
 
@@ -68,6 +70,9 @@ void SharedHashTableController::signal(int my_node_id, Status status) {
         it->second->status = status;
         _shared_contexts.erase(it);
     }
+    for (auto& dep : _dependencies) {
+        dep->set_ready_for_write();
+    }
     _cv.notify_all();
 }
 
@@ -78,6 +83,9 @@ void SharedHashTableController::signal(int my_node_id) {
         it->second->signaled = true;
         _shared_contexts.erase(it);
     }
+    for (auto& dep : _dependencies) {
+        dep->set_ready_for_write();
+    }
     _cv.notify_all();
 }