diff --git a/be/src/pipeline/exec/hashjoin_build_sink.h b/be/src/pipeline/exec/hashjoin_build_sink.h index 5ea504d488daf92..765333fed214f64 100644 --- 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 StreamingOperatorcan_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 index be94dacdcaef3b5..2e92b08061cc858 100644 --- 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; }