diff --git a/be/src/runtime/runtime_filter_mgr.cpp b/be/src/runtime/runtime_filter_mgr.cpp index abfa40847014a9..73fcae57fcef27 100644 --- a/be/src/runtime/runtime_filter_mgr.cpp +++ b/be/src/runtime/runtime_filter_mgr.cpp @@ -39,7 +39,6 @@ #include "runtime/runtime_state.h" #include "runtime/thread_context.h" #include "util/brpc_client_cache.h" -#include "util/spinlock.h" namespace doris { @@ -227,7 +226,7 @@ Status RuntimeFilterMergeControllerEntity::_init_with_desc( auto filter_id = runtime_filter_desc->filter_id; // LOG(INFO) << "entity filter id:" << filter_id; cntVal->filter->init_with_desc(&cntVal->runtime_filter_desc, query_options, -1, false); - _filter_map.emplace(filter_id, CntlValwithLock {cntVal, std::make_unique()}); + _filter_map.emplace(filter_id, CntlValwithLock {cntVal, std::make_unique()}); return Status::OK(); } @@ -249,7 +248,7 @@ Status RuntimeFilterMergeControllerEntity::_init_with_desc( auto filter_id = runtime_filter_desc->filter_id; // LOG(INFO) << "entity filter id:" << filter_id; cntVal->filter->init_with_desc(&cntVal->runtime_filter_desc, query_options); - _filter_map.emplace(filter_id, CntlValwithLock {cntVal, std::make_unique()}); + _filter_map.emplace(filter_id, CntlValwithLock {cntVal, std::make_unique()}); return Status::OK(); } @@ -323,7 +322,7 @@ Status RuntimeFilterMergeControllerEntity::merge(const PMergeFilterRequest* requ // iter->second = pair{CntlVal,SpinLock} cntVal = iter->second.first; { - std::lock_guard l(*iter->second.second); + std::lock_guard l(*iter->second.second); MergeRuntimeFilterParams params(request, attach_data); ObjectPool* pool = cntVal->pool.get(); RuntimeFilterWrapperHolder holder; diff --git a/be/src/runtime/runtime_filter_mgr.h b/be/src/runtime/runtime_filter_mgr.h index 2048229cd2e928..187fa374526611 100644 --- a/be/src/runtime/runtime_filter_mgr.h +++ b/be/src/runtime/runtime_filter_mgr.h @@ -170,7 +170,7 @@ class RuntimeFilterMergeControllerEntity { std::shared_mutex _filter_map_mutex; std::shared_ptr _mem_tracker; using CntlValwithLock = - std::pair, std::unique_ptr>; + std::pair, std::unique_ptr>; std::map _filter_map; RuntimeState* _state; bool _opt_remote_rf = true;