[doris] branch master updated: [runtime filter](profile) add merge time on non-pipeline engine (#22363)

[gabriellee]

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 <gabrielleeb...@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-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org