From f806d9d2845f7f5f1c509cbdb64c918196473b31 Mon Sep 17 00:00:00 2001 From: BiteTheDDDDt Date: Sun, 1 Dec 2024 21:14:02 +0800 Subject: [PATCH] fix --- be/src/pipeline/exec/hashjoin_build_sink.cpp | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/be/src/pipeline/exec/hashjoin_build_sink.cpp b/be/src/pipeline/exec/hashjoin_build_sink.cpp index 503e3d01f871e3..cec0c77da8a61d 100644 --- a/be/src/pipeline/exec/hashjoin_build_sink.cpp +++ b/be/src/pipeline/exec/hashjoin_build_sink.cpp @@ -148,9 +148,7 @@ Status HashJoinBuildSinkLocalState::close(RuntimeState* state, Status exec_statu // do not publish filter coz local rf not inited and useless return Base::close(state, exec_status); } - } - - if (_should_build_hash_table) { + } else if (_should_build_hash_table) { if (p._shared_hashtable_controller && !p._shared_hash_table_context->complete_build_stage) { return Status::InternalError("close before sink meet eos"); }