diff --git a/ydb/core/tx/columnshard/blobs_action/transaction/tx_write.cpp b/ydb/core/tx/columnshard/blobs_action/transaction/tx_write.cpp index b7686d8f147b..f4bd0b230378 100644 --- a/ydb/core/tx/columnshard/blobs_action/transaction/tx_write.cpp +++ b/ydb/core/tx/columnshard/blobs_action/transaction/tx_write.cpp @@ -30,6 +30,7 @@ bool TTxWrite::InsertOneBlob(TTransactionContext& txc, const NOlap::TWideSeriali } bool TTxWrite::Execute(TTransactionContext& txc, const TActorContext&) { + TMemoryProfileGuard mpg("TTxWrite::Execute"); NActors::TLogContextGuard logGuard = NActors::TLogContextBuilder::Build(NKikimrServices::TX_COLUMNSHARD)("tablet_id", Self->TabletID())("tx_state", "execute"); ACFL_DEBUG("event", "start_execute"); const NOlap::TWritingBuffer& buffer = PutBlobResult->Get()->MutableWritesBuffer(); @@ -114,6 +115,7 @@ void TTxWrite::OnProposeError(TTxController::TProposeResult& proposeResult, cons } void TTxWrite::Complete(const TActorContext& ctx) { + TMemoryProfileGuard mpg("TTxWrite::Complete"); NActors::TLogContextGuard logGuard = NActors::TLogContextBuilder::Build(NKikimrServices::TX_COLUMNSHARD)("tablet_id", Self->TabletID())("tx_state", "complete"); const auto now = TMonotonic::Now(); const NOlap::TWritingBuffer& buffer = PutBlobResult->Get()->MutableWritesBuffer(); diff --git a/ydb/core/tx/columnshard/blobs_action/transaction/tx_write_index.cpp b/ydb/core/tx/columnshard/blobs_action/transaction/tx_write_index.cpp index fc687804123b..977adb585ea6 100644 --- a/ydb/core/tx/columnshard/blobs_action/transaction/tx_write_index.cpp +++ b/ydb/core/tx/columnshard/blobs_action/transaction/tx_write_index.cpp @@ -8,6 +8,7 @@ namespace NKikimr::NColumnShard { bool TTxWriteIndex::Execute(TTransactionContext& txc, const TActorContext& ctx) { auto changes = Ev->Get()->IndexChanges; + TMemoryProfileGuard mpg("TTxWriteIndex::Execute::" + changes->TypeString()); TLogContextGuard gLogging = NActors::TLogContextBuilder::Build(NKikimrServices::TX_COLUMNSHARD)("tablet_id", Self->TabletID())("external_task_id", changes->GetTaskIdentifier()); Y_ABORT_UNLESS(Self->InsertTable); Y_ABORT_UNLESS(Self->TablesManager.HasPrimaryIndex()); @@ -52,6 +53,7 @@ void TTxWriteIndex::Complete(const TActorContext& ctx) { TLogContextGuard gLogging(NActors::TLogContextBuilder::Build(NKikimrServices::TX_COLUMNSHARD)("tablet_id", Self->TabletID())); CompleteReady = true; auto changes = Ev->Get()->IndexChanges; + TMemoryProfileGuard mpg("TTxWriteIndex::Complete::" + changes->TypeString()); ACFL_DEBUG("event", "TTxWriteIndex::Complete")("change_type", changes->TypeString())("details", changes->DebugString()); const ui64 blobsWritten = changes->GetBlobsAction().GetWritingBlobsCount();