BiteTheDDDDt commented on code in PR #64851:
URL: https://github.com/apache/doris/pull/64851#discussion_r3473440385
##########
be/src/exec/runtime_filter/runtime_filter_mgr.cpp:
##########
@@ -428,6 +643,71 @@ Status
RuntimeFilterMergeControllerEntity::_send_rf_to_target(GlobalMergeContext
}
std::vector<TRuntimeFilterTargetParamsV2>& targets = cnt_val.targetv2_info;
+ int timeout_ms = get_execution_rpc_timeout_ms(execution_timeout);
+ int64_t max_send_bytes =
query_options.__isset.runtime_filter_tree_publish_max_send_bytes
+ ?
query_options.runtime_filter_tree_publish_max_send_bytes
+ :
DEFAULT_RUNTIME_FILTER_TREE_PUBLISH_MAX_SEND_BYTES;
+ DORIS_CHECK(max_send_bytes >= 0);
+ apply_request.set_merge_time(merge_time);
+ *apply_request.mutable_query_id() = query_id;
+ const int64_t serialized_filter_size =
+ static_cast<int64_t>(apply_request.ByteSizeLong()) + std::max(0,
len);
+ const bool has_tree_publish_targets =
can_use_tree_publish_targets(targets);
+ const int fanout =
+ calculate_tree_publish_fanout(serialized_filter_size,
targets.size(), max_send_bytes);
+ const bool use_tree_publish =
+ fanout > 0 && has_tree_publish_targets && targets.size() >
static_cast<size_t>(fanout);
+
+ if (use_tree_publish) {
+ apply_request.set_tree_publish_fanout(fanout);
+ apply_request.set_publish_rpc_timeout_ms(timeout_ms);
+ auto publish_targets = build_runtime_filter_publish_targets(targets);
+ auto tasks = build_runtime_filter_publish_tasks(apply_request,
publish_targets, fanout);
+ cnt_val.publish_callbacks.resize(tasks.size());
+ LOG(INFO) << "Runtime filter tree publish filter_id=" <<
apply_request.filter_id()
Review Comment:
不要乱打log info，整体检查一下这种行为
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
