[incubator-doris] 07/19: [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 dev-1.0.1
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git

commit 6c879d86c2fd42b729e5cb1fc5fd2457aa101d23
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 60bad52ea1..433c01160d 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 8c43637d13..7e0f2bf211 100644
--- a/be/src/util/runtime_profile.h
+++ b/be/src/util/runtime_profile.h
@@ -437,9 +437,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 32d5255aed..249f70ac0f 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