diff --git a/be/src/runtime/load_stream_mgr.cpp b/be/src/runtime/load_stream_mgr.cpp
index 5c50466290..d1af7b60d3 100644
--- a/be/src/runtime/load_stream_mgr.cpp
+++ b/be/src/runtime/load_stream_mgr.cpp
@@ -50,7 +50,7 @@ Status LoadStreamMgr::open_load_stream(const POpenStreamSinkRequest* request,
     UniqueId load_id(request->load_id());
 
     {
-        std::lock_guard l(_lock);
+        std::lock_guard<decltype(_lock)> l(_lock);
         auto it = _load_streams_map.find(load_id);
         if (it != _load_streams_map.end()) {
             load_stream = it->second;
@@ -66,7 +66,7 @@ Status LoadStreamMgr::open_load_stream(const POpenStreamSinkRequest* request,
 }
 
 void LoadStreamMgr::clear_load(UniqueId load_id) {
-    std::lock_guard l(_lock);
+    std::lock_guard<decltype(_lock)> l(_lock);
     _load_streams_map.erase(load_id);
 }
 
diff --git a/be/src/runtime/load_stream_mgr.h b/be/src/runtime/load_stream_mgr.h
index 73a14b08f7..da3ae98a42 100644
--- a/be/src/runtime/load_stream_mgr.h
+++ b/be/src/runtime/load_stream_mgr.h
@@ -53,7 +53,7 @@ public:
     FifoThreadPool* light_work_pool() { return _light_work_pool; }
 
 private:
-    bthread::Mutex _lock;
+    std::mutex _lock;
     std::unordered_map<UniqueId, LoadStreamSharedPtr> _load_streams_map;
     std::unique_ptr<ThreadPool> _file_writer_thread_pool;