[incubator-doris] branch master updated: [refactor] remove useless code (#8773)

[mo...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git


The following commit(s) were added to refs/heads/master by this push:
     new f3539cd  [refactor] remove useless code (#8773)
f3539cd is described below

commit f3539cd3ba70ac38e250925871c5c86f4402c88b
Author: dataroaring <98...@users.noreply.github.com>
AuthorDate: Sat Apr 2 10:28:16 2022 +0800

    [refactor] remove useless code (#8773)
---
 be/src/util/runtime_profile.cpp         | 1 -
 be/src/util/runtime_profile.h           | 3 ---
 be/src/vec/sink/vdata_stream_sender.cpp | 1 -
 3 files changed, 5 deletions(-)

diff --git a/be/src/util/runtime_profile.cpp b/be/src/util/runtime_profile.cpp
index 1b11f0d..263c31e 100644
--- a/be/src/util/runtime_profile.cpp
+++ b/be/src/util/runtime_profile.cpp
@@ -45,7 +45,6 @@ static const std::string ROOT_COUNTER = "";
 
 RuntimeProfile::RuntimeProfile(const std::string& name, bool is_averaged_profile)
         : _pool(new ObjectPool()),
-          _own_pool(false),
           _name(name),
           _metadata(-1),
           _is_averaged_profile(is_averaged_profile),
diff --git a/be/src/util/runtime_profile.h b/be/src/util/runtime_profile.h
index 0155bbe..8911d84 100644
--- a/be/src/util/runtime_profile.h
+++ b/be/src/util/runtime_profile.h
@@ -401,9 +401,6 @@ private:
     // Pool for allocated counters. These counters are shared with some other objects.
     std::map<std::string, std::shared_ptr<HighWaterMarkCounter>> _shared_counter_pool;
 
-    // True if we have to delete the _pool on destruction.
-    bool _own_pool;
-
     // Name for this runtime profile.
     std::string _name;
 
diff --git a/be/src/vec/sink/vdata_stream_sender.cpp b/be/src/vec/sink/vdata_stream_sender.cpp
index 31d8fd6..46df1dc 100644
--- a/be/src/vec/sink/vdata_stream_sender.cpp
+++ b/be/src/vec/sink/vdata_stream_sender.cpp
@@ -55,7 +55,6 @@ Status VDataStreamSender::Channel::init(RuntimeState* state) {
     _brpc_request.set_be_number(_be_number);
 
     _brpc_timeout_ms = std::min(3600, state->query_options().query_timeout) * 1000;
-    _brpc_stub = state->exec_env()->brpc_internal_client_cache()->get_client(_brpc_dest_addr);
 
     if (_brpc_dest_addr.hostname == BackendOptions::get_localhost()) {
         _brpc_stub = state->exec_env()->brpc_internal_client_cache()->get_client(

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org