You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by ga...@apache.org on 2023/07/31 04:52:49 UTC
[doris] branch master updated: [runtime filter](profile) add merge time on non-pipeline engine (#22363)
This is an automated email from the ASF dual-hosted git repository.
gabriellee pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new b64f62647b [runtime filter](profile) add merge time on non-pipeline engine (#22363)
b64f62647b is described below
commit b64f62647b152ac660ac5a89703fa50f750970cd
Author: Gabriel <ga...@gmail.com>
AuthorDate: Mon Jul 31 12:52:42 2023 +0800
[runtime filter](profile) add merge time on non-pipeline engine (#22363)
---
be/src/exprs/runtime_filter.cpp | 2 ++
be/src/runtime/runtime_filter_mgr.cpp | 1 +
gensrc/proto/internal_service.proto | 1 +
3 files changed, 4 insertions(+)
diff --git a/be/src/exprs/runtime_filter.cpp b/be/src/exprs/runtime_filter.cpp
index e4a1b34a63..e1abc0f55d 100644
--- a/be/src/exprs/runtime_filter.cpp
+++ b/be/src/exprs/runtime_filter.cpp
@@ -1810,6 +1810,8 @@ Status IRuntimeFilter::update_filter(const UpdateRuntimeFilterParams* param) {
update_runtime_filter_type_to_profile();
}
this->signal();
+
+ _profile->add_info_string("MergeTime", std::to_string(param->request->merge_time()) + " ms");
return Status::OK();
}
diff --git a/be/src/runtime/runtime_filter_mgr.cpp b/be/src/runtime/runtime_filter_mgr.cpp
index 6614532d85..54b83c5330 100644
--- a/be/src/runtime/runtime_filter_mgr.cpp
+++ b/be/src/runtime/runtime_filter_mgr.cpp
@@ -446,6 +446,7 @@ Status RuntimeFilterMergeControllerEntity::merge(const PMergeFilterRequest* requ
rpc_contexts[cur]->request.set_filter_id(request->filter_id());
rpc_contexts[cur]->request.set_is_pipeline(request->has_is_pipeline() &&
request->is_pipeline());
+ rpc_contexts[cur]->request.set_merge_time(merge_time);
*rpc_contexts[cur]->request.mutable_query_id() = request->query_id();
if (has_attachment) {
rpc_contexts[cur]->cntl.request_attachment().append(request_attachment);
diff --git a/gensrc/proto/internal_service.proto b/gensrc/proto/internal_service.proto
index 08a3240e00..de1f7876dc 100644
--- a/gensrc/proto/internal_service.proto
+++ b/gensrc/proto/internal_service.proto
@@ -501,6 +501,7 @@ message PPublishFilterRequest {
optional PBloomFilter bloom_filter = 6;
optional PInFilter in_filter = 7;
optional bool is_pipeline = 8;
+ optional int64 merge_time = 9;
};
message PPublishFilterRequestV2 {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org