From b65eba6552ba464fbd8c540ae1adb60da1b032b1 Mon Sep 17 00:00:00 2001 From: BiteTheDDDDt Date: Tue, 15 Oct 2024 17:43:17 +0800 Subject: [PATCH 1/2] set some rf brpc request to ignore_eovercrowded --- be/src/exprs/runtime_filter.cpp | 3 +++ 1 file changed, 3 insertions(+) diff --git a/be/src/exprs/runtime_filter.cpp b/be/src/exprs/runtime_filter.cpp index 4e9a12b5bc5fea..9525ccc4055932 100644 --- a/be/src/exprs/runtime_filter.cpp +++ b/be/src/exprs/runtime_filter.cpp @@ -1121,6 +1121,8 @@ 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 +1161,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); From 10cacef3fd5d28358cbcca6181b113c8278f1328 Mon Sep 17 00:00:00 2001 From: BiteTheDDDDt Date: Tue, 15 Oct 2024 17:43:48 +0800 Subject: [PATCH 2/2] format --- be/src/exprs/runtime_filter.cpp | 1 - 1 file changed, 1 deletion(-) diff --git a/be/src/exprs/runtime_filter.cpp b/be/src/exprs/runtime_filter.cpp index 9525ccc4055932..9d6fb2ab3ce1c6 100644 --- a/be/src/exprs/runtime_filter.cpp +++ b/be/src/exprs/runtime_filter.cpp @@ -1123,7 +1123,6 @@ Status IRuntimeFilter::send_filter_size(RuntimeState* state, uint64_t local_filt 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()); closure.release();