diff --git a/be/src/olap/rowset/segcompaction.cpp b/be/src/olap/rowset/segcompaction.cpp index 6eb5fc04bef157..99d7935351d5d5 100644 --- a/be/src/olap/rowset/segcompaction.cpp +++ b/be/src/olap/rowset/segcompaction.cpp @@ -67,15 +67,13 @@ namespace doris { using namespace ErrorCode; -std::atomic seg_compaction_counter(0); - SegcompactionWorker::SegcompactionWorker(BetaRowsetWriter* writer) : _writer(writer) {} void SegcompactionWorker::init_mem_tracker(int64_t txn_id, PUniqueId load_id) { _seg_compact_mem_tracker = MemTrackerLimiter::create_shared( MemTrackerLimiter::Type::COMPACTION, - fmt::format("segcompaction-txnID_{}-loadID_{}_{}", std::to_string(txn_id), - print_id(load_id), seg_compaction_counter.fetch_add(1))); + fmt::format("segcompaction-txnID_{}-loadID_{}", std::to_string(txn_id), + print_id(load_id))); } Status SegcompactionWorker::_get_segcompaction_reader( diff --git a/be/src/runtime/memory/mem_tracker_limiter.cpp b/be/src/runtime/memory/mem_tracker_limiter.cpp index 501e82b53b32e1..c4484cbb143d90 100644 --- a/be/src/runtime/memory/mem_tracker_limiter.cpp +++ b/be/src/runtime/memory/mem_tracker_limiter.cpp @@ -39,6 +39,7 @@ namespace doris { static bvar::Adder memory_memtrackerlimiter_cnt("memory_memtrackerlimiter_cnt"); +std::atomic mem_tracker_number_counter(0); std::atomic mem_tracker_limiter_group_counter(0); constexpr auto GC_MAX_SEEK_TRACKER = 1000; @@ -61,7 +62,8 @@ static RuntimeProfile::Counter* previously_canceling_tasks_counter = MemTrackerLimiter::MemTrackerLimiter(Type type, const std::string& label, int64_t byte_limit) { DCHECK_GE(byte_limit, -1); _type = type; - _label = label; + // MemTrackerLimiter labels cannot be repeated, otherwise generation Runtime Profile will fail. + _label = fmt::format("{}_{}", label, mem_tracker_number_counter.fetch_add(1)); _limit = byte_limit; if (_type == Type::GLOBAL) { _group_num = 0;