diff --git a/be/src/fs/s3/poco_common.cpp b/be/src/fs/s3/poco_common.cpp index 7c84d775cd2..139beeb3bc1 100644 --- a/be/src/fs/s3/poco_common.cpp +++ b/be/src/fs/s3/poco_common.cpp @@ -92,7 +92,6 @@ HTTPSessionPtr makeHTTPSessionImpl(const std::string& host, Poco::UInt16 port, b } EndpointHTTPSessionPool::Base::ObjectPtr EndpointHTTPSessionPool::allocObject() { - SCOPED_THREAD_LOCAL_MEM_TRACKER_SETTER(_mem_tracker); auto session = makeHTTPSessionImpl(_host, _port, _is_https, true); return session; } diff --git a/be/src/fs/s3/poco_common.h b/be/src/fs/s3/poco_common.h index 5c368c40dda..0711e20e5ed 100644 --- a/be/src/fs/s3/poco_common.h +++ b/be/src/fs/s3/poco_common.h @@ -68,9 +68,7 @@ class EndpointHTTPSessionPool : public PoolBase { public: using Base = PoolBase; EndpointHTTPSessionPool(std::string host, uint16_t port, bool is_https) - : Base(ENDPOINT_POOL_SIZE), _host(std::move(host)), _port(port), _is_https(is_https) { - _mem_tracker = GlobalEnv::GetInstance()->poco_connection_pool_mem_tracker(); - } + : Base(ENDPOINT_POOL_SIZE), _host(std::move(host)), _port(port), _is_https(is_https) {} private: ObjectPtr allocObject() override; @@ -80,7 +78,6 @@ private: const std::string _host; const uint16_t _port; const bool _is_https; - MemTracker* _mem_tracker = nullptr; }; class HTTPSessionPools { diff --git a/be/src/runtime/exec_env.cpp b/be/src/runtime/exec_env.cpp index 8574d53c721..7616cadea41 100644 --- a/be/src/runtime/exec_env.cpp +++ b/be/src/runtime/exec_env.cpp @@ -241,7 +241,6 @@ Status GlobalEnv::_init_mem_tracker() { _consistency_mem_tracker = regist_tracker(MemTrackerType::CONSISTENCY, consistency_mem_limit, process_mem_tracker()); _datacache_mem_tracker = regist_tracker(MemTrackerType::DATACACHE, -1, process_mem_tracker()); - _poco_connection_pool_mem_tracker = regist_tracker(MemTrackerType::POCO_CONNECTION_POOL, -1, process_mem_tracker()); _replication_mem_tracker = regist_tracker(MemTrackerType::REPLICATION, -1, process_mem_tracker()); MemChunkAllocator::init_metrics(); diff --git a/be/src/runtime/exec_env.h b/be/src/runtime/exec_env.h index 4936ab4372e..f735fb22a25 100644 --- a/be/src/runtime/exec_env.h +++ b/be/src/runtime/exec_env.h @@ -160,7 +160,6 @@ public: MemTracker* consistency_mem_tracker() { return _consistency_mem_tracker.get(); } MemTracker* replication_mem_tracker() { return _replication_mem_tracker.get(); } MemTracker* datacache_mem_tracker() { return _datacache_mem_tracker.get(); } - MemTracker* poco_connection_pool_mem_tracker() { return _poco_connection_pool_mem_tracker.get(); } MemTracker* jemalloc_metadata_traker() { return _jemalloc_metadata_tracker.get(); } std::shared_ptr get_mem_tracker_by_type(MemTrackerType type); std::vector> mem_trackers() const; @@ -235,9 +234,6 @@ private: // The memory used for datacache std::shared_ptr _datacache_mem_tracker; - // The memory used for poco connection pool - std::shared_ptr _poco_connection_pool_mem_tracker; - std::map> _mem_tracker_map; }; diff --git a/be/src/runtime/mem_tracker.cpp b/be/src/runtime/mem_tracker.cpp index c561d617802..035b776ee0d 100644 --- a/be/src/runtime/mem_tracker.cpp +++ b/be/src/runtime/mem_tracker.cpp @@ -72,7 +72,6 @@ static std::vector> s_mem_types = { {MemTrackerType::UPDATE, "update"}, {MemTrackerType::CLONE, "clone"}, {MemTrackerType::DATACACHE, "datacache"}, - {MemTrackerType::POCO_CONNECTION_POOL, "poco_connection_pool"}, {MemTrackerType::REPLICATION, "replication"}, {MemTrackerType::ROWSET_UPDATE_STATE, "rowset_update_state"}, {MemTrackerType::INDEX_CACHE, "index_cache"}, diff --git a/be/src/runtime/mem_tracker.h b/be/src/runtime/mem_tracker.h index 08cd581f289..751faf9e449 100644 --- a/be/src/runtime/mem_tracker.h +++ b/be/src/runtime/mem_tracker.h @@ -111,7 +111,6 @@ enum class MemTrackerType { UPDATE, CLONE, DATACACHE, - POCO_CONNECTION_POOL, REPLICATION, ROWSET_UPDATE_STATE, INDEX_CACHE,