From a03e5e0d1876e2542754544ce1ba99937a3b83f0 Mon Sep 17 00:00:00 2001 From: BiteTheDDDDt Date: Wed, 9 Oct 2024 16:24:45 +0800 Subject: [PATCH] update --- be/src/pipeline/exec/hashjoin_build_sink.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/be/src/pipeline/exec/hashjoin_build_sink.cpp b/be/src/pipeline/exec/hashjoin_build_sink.cpp index 93d22850dfcbb1..e72904cb0ce55e 100644 --- a/be/src/pipeline/exec/hashjoin_build_sink.cpp +++ b/be/src/pipeline/exec/hashjoin_build_sink.cpp @@ -135,7 +135,7 @@ Status HashJoinBuildSinkLocalState::close(RuntimeState* state, Status exec_statu } }}; - if (!_runtime_filter_slots || _runtime_filters.empty() || state->is_cancelled() || !_eos) { + if (!_runtime_filter_slots || _runtime_filters.empty() || state->is_cancelled()) { return Base::close(state, exec_status); } auto* block = _shared_state->build_block.get();