Skip to content

Commit

Permalink
12
Browse files Browse the repository at this point in the history
  • Loading branch information
xinyiZzz committed Sep 28, 2024
1 parent 2b563cb commit 1b8a421
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions be/src/olap/rowset/segcompaction.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -67,13 +67,15 @@
namespace doris {
using namespace ErrorCode;

std::atomic<long> 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)));
fmt::format("segcompaction-txnID_{}-loadID_{}_{}", std::to_string(txn_id),
print_id(load_id), seg_compaction_counter.fetch_add(1)));
}

Status SegcompactionWorker::_get_segcompaction_reader(
Expand Down

0 comments on commit 1b8a421

Please sign in to comment.