diff --git a/be/src/runtime/runtime_filter_mgr.cpp b/be/src/runtime/runtime_filter_mgr.cpp index 050f122e0a..5b61cc8736 100644 --- a/be/src/runtime/runtime_filter_mgr.cpp +++ b/be/src/runtime/runtime_filter_mgr.cpp @@ -416,12 +416,7 @@ Status RuntimeFilterMergeControllerEntity::merge(const PMergeFilterRequest* requ RuntimeFilterWrapperHolder holder; RETURN_IF_ERROR(IRuntimeFilter::create_wrapper(¶ms, pool, holder.getHandle())); - auto st = cnt_val->filter->merge_from(holder.getHandle()->get()); - if (!st) { - // prevent error ignored - DCHECK(false) << st.msg(); - return st; - } + RETURN_IF_ERROR(cnt_val->filter->merge_from(holder.getHandle()->get())); cnt_val->arrive_id.insert(UniqueId(request->fragment_instance_id())); merged_size = cnt_val->arrive_id.size();