[improve](join) remove join probe dependency of wait rf

zhangstar333 · Jan 10, 2024 · 8befa64 · 8befa64
1 parent c1a2734
commit 8befa64
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 8 deletions.
diff --git a/be/src/pipeline/exec/hashjoin_build_sink.h b/be/src/pipeline/exec/hashjoin_build_sink.h
@@ -41,7 +41,6 @@ class HashJoinBuildSink final : public StreamingOperator<vectorized::HashJoinNod
 public:
     HashJoinBuildSink(OperatorBuilderBase* operator_builder, ExecNode* node);
     bool can_write() override { return _node->can_sink_write(); }
-    bool is_pending_finish() const override { return !_node->ready_for_finish(); }
 };
 
 class HashJoinBuildSinkOperatorX;

diff --git a/be/src/vec/exec/join/vhash_join_node.h b/be/src/vec/exec/join/vhash_join_node.h
@@ -244,13 +244,6 @@ class HashJoinNode final : public VJoinNodeBase {
 
     bool should_build_hash_table() const { return _should_build_hash_table; }
 
-    bool ready_for_finish() {
-        if (_runtime_filter_slots == nullptr) {
-            return true;
-        }
-        return _runtime_filter_slots->ready_finish_publish();
-    }
-
     bool have_other_join_conjunct() const { return _have_other_join_conjunct; }
     bool is_right_semi_anti() const { return _is_right_semi_anti; }
     bool is_outer_join() const { return _is_outer_join; }