diff --git a/be/src/exprs/runtime_filter.cpp b/be/src/exprs/runtime_filter.cpp index 4e9a12b5bc5fea..9d6fb2ab3ce1c6 100644 --- a/be/src/exprs/runtime_filter.cpp +++ b/be/src/exprs/runtime_filter.cpp @@ -1121,6 +1121,7 @@ Status IRuntimeFilter::send_filter_size(RuntimeState* state, uint64_t local_filt request->set_filter_size(local_filter_size); request->set_filter_id(_filter_id); callback->cntl_->set_timeout_ms(std::min(3600, state->execution_timeout()) * 1000); + callback->cntl_->ignore_eovercrowded(); stub->send_filter_size(closure->cntl_.get(), closure->request_.get(), closure->response_.get(), closure.get()); @@ -1159,6 +1160,7 @@ Status IRuntimeFilter::push_to_remote(const TNetworkAddress* addr, bool opt_remo auto column_type = _wrapper->column_type(); merge_filter_request->set_column_type(to_proto(column_type)); merge_filter_callback->cntl_->set_timeout_ms(wait_time_ms()); + merge_filter_callback->cntl_->ignore_eovercrowded(); if (get_ignored()) { merge_filter_request->set_filter_type(PFilterType::UNKNOW_FILTER);