fix

apache · Dec 1, 2024 · f806d9d · f806d9d
1 parent 8d7e032
commit f806d9d
Showing 1 changed file with 1 addition and 3 deletions.
diff --git 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");
         }