This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 55d969fc4c0 fix compile
55d969fc4c0 is described below
commit 55d969fc4c079c3af6eaf5c4075c2426f31b69e6
Author: yiguolei <[email protected]>
AuthorDate: Thu Apr 11 12:08:26 2024 +0800
fix compile
---
be/src/service/internal_service.cpp | 16 ++++++++--------
1 file changed, 8 insertions(+), 8 deletions(-)
diff --git a/be/src/service/internal_service.cpp
b/be/src/service/internal_service.cpp
index 9eeeca68db6..be5bc1f0acc 100644
--- a/be/src/service/internal_service.cpp
+++ b/be/src/service/internal_service.cpp
@@ -1203,10 +1203,10 @@ void
PInternalServiceImpl::merge_filter(::google::protobuf::RpcController* contr
}
}
-void PInternalService::send_filter_size(::google::protobuf::RpcController*
controller,
- const ::doris::PSendFilterSizeRequest*
request,
- ::doris::PSendFilterSizeResponse*
response,
- ::google::protobuf::Closure* done) {
+void PInternalServiceImpl::send_filter_size(::google::protobuf::RpcController*
controller,
+ const
::doris::PSendFilterSizeRequest* request,
+ ::doris::PSendFilterSizeResponse*
response,
+ ::google::protobuf::Closure* done)
{
bool ret = _light_work_pool.try_offer([this, request, response, done]() {
brpc::ClosureGuard closure_guard(done);
Status st = _exec_env->fragment_mgr()->send_filter_size(request);
@@ -1218,10 +1218,10 @@ void
PInternalService::send_filter_size(::google::protobuf::RpcController* contr
}
}
-void PInternalService::sync_filter_size(::google::protobuf::RpcController*
controller,
- const ::doris::PSyncFilterSizeRequest*
request,
- ::doris::PSyncFilterSizeResponse*
response,
- ::google::protobuf::Closure* done) {
+void PInternalServiceImpl::sync_filter_size(::google::protobuf::RpcController*
controller,
+ const
::doris::PSyncFilterSizeRequest* request,
+ ::doris::PSyncFilterSizeResponse*
response,
+ ::google::protobuf::Closure* done)
{
bool ret = _light_work_pool.try_offer([this, request, response, done]() {
brpc::ClosureGuard closure_guard(done);
Status st = _exec_env->fragment_mgr()->sync_filter_size(request);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
