Skip to content

Commit 0739991

Browse files
authored
[Improvement](runtime-filter) set some rf brpc request to ignore_eovercrowded (#41698)
## Proposed changes set some rf brpc request to ignore_eovercrowded
1 parent 1b4cf4c commit 0739991

File tree

2 files changed

+4
-0
lines changed

2 files changed

+4
-0
lines changed

be/src/exprs/runtime_filter.cpp

+2
Original file line numberDiff line numberDiff line change
@@ -1144,6 +1144,7 @@ Status IRuntimeFilter::send_filter_size(RuntimeState* state, uint64_t local_filt
11441144
request->set_filter_size(local_filter_size);
11451145
request->set_filter_id(_filter_id);
11461146
callback->cntl_->set_timeout_ms(std::min(3600, state->execution_timeout()) * 1000);
1147+
callback->cntl_->ignore_eovercrowded();
11471148

11481149
stub->send_filter_size(closure->cntl_.get(), closure->request_.get(), closure->response_.get(),
11491150
closure.get());
@@ -1181,6 +1182,7 @@ Status IRuntimeFilter::push_to_remote(const TNetworkAddress* addr) {
11811182
auto column_type = _wrapper->column_type();
11821183
RETURN_IF_CATCH_EXCEPTION(merge_filter_request->set_column_type(to_proto(column_type)));
11831184
merge_filter_callback->cntl_->set_timeout_ms(wait_time_ms());
1185+
merge_filter_callback->cntl_->ignore_eovercrowded();
11841186

11851187
if (get_ignored()) {
11861188
merge_filter_request->set_filter_type(PFilterType::UNKNOW_FILTER);

be/src/runtime/runtime_filter_mgr.cpp

+2
Original file line numberDiff line numberDiff line change
@@ -342,6 +342,7 @@ Status RuntimeFilterMergeControllerEntity::send_filter_size(const PSendFilterSiz
342342
pquery_id->set_hi(_state->query_id.hi());
343343
pquery_id->set_lo(_state->query_id.lo());
344344
closure->cntl_->set_timeout_ms(std::min(3600, _state->execution_timeout) * 1000);
345+
closure->cntl_->ignore_eovercrowded();
345346

346347
closure->request_->set_filter_id(filter_id);
347348
closure->request_->set_filter_size(cnt_val->global_size);
@@ -454,6 +455,7 @@ Status RuntimeFilterMergeControllerEntity::merge(const PMergeFilterRequest* requ
454455
closure->cntl_->request_attachment().append(request_attachment);
455456
}
456457
closure->cntl_->set_timeout_ms(std::min(3600, _state->execution_timeout) * 1000);
458+
closure->cntl_->ignore_eovercrowded();
457459
// set fragment-id
458460
for (auto& target_fragment_instance_id : target.target_fragment_instance_ids) {
459461
PUniqueId* cur_id = closure->request_->add_fragment_instance_ids();

0 commit comments

Comments
 (0)