diff --git a/be/src/pipeline/exec/set_probe_sink_operator.cpp b/be/src/pipeline/exec/set_probe_sink_operator.cpp index 744c8b17e2..7688bce00e 100644 --- a/be/src/pipeline/exec/set_probe_sink_operator.cpp +++ b/be/src/pipeline/exec/set_probe_sink_operator.cpp @@ -123,8 +123,8 @@ Status SetProbeSinkOperatorX::sink(RuntimeState* state, vectorized process_hashtable_ctx(&local_state, probe_rows); return process_hashtable_ctx.mark_data_in_hashtable(arg); } else { - LOG(FATAL) << "FATAL: uninited hash table"; - __builtin_unreachable(); + LOG(WARNING) << "Uninited hash table in Set Probe Sink Operator"; + return Status::OK(); } }, *local_state._shared_state->hash_table_variants)); @@ -283,8 +283,7 @@ void SetProbeSinkOperatorX::_refresh_hash_table( arg.hash_table = std::move(tmp_hash_table); } } else { - LOG(FATAL) << "FATAL: uninited hash table"; - __builtin_unreachable(); + LOG(WARNING) << "Uninited hash table in Set Probe Sink Operator"; } }, *hash_table_variants); diff --git a/be/src/pipeline/pipeline_x/dependency.h b/be/src/pipeline/pipeline_x/dependency.h index dfdb13b441..be28769272 100644 --- a/be/src/pipeline/pipeline_x/dependency.h +++ b/be/src/pipeline/pipeline_x/dependency.h @@ -613,7 +613,7 @@ public: /// init in setup_local_state std::unique_ptr hash_table_variants = - nullptr; // the real data HERE. + std::make_unique(); // the real data HERE. std::vector build_not_ignore_null; /// init in both upstream side.