Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
ivanmorozov333 committed Dec 12, 2024
1 parent c63e6f2 commit 045abc1
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions ydb/core/tx/columnshard/columnshard__write.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -537,7 +537,7 @@ void TColumnShard::Handle(NEvents::TDataEvents::TEvWrite::TPtr& ev, const TActor
return;
}

TMemoryProfileGuard mpg2("NEvents::TDataEvents::TEvWrite::Continue::21");
TMemoryProfileGuard mpg21("NEvents::TDataEvents::TEvWrite::Continue::21");
auto schema = TablesManager.GetPrimaryIndex()->GetVersionedIndex().GetSchemaOptional(operation.GetTableId().GetSchemaVersion());
if (!schema) {
sendError("unknown schema version", NKikimrDataEvents::TEvWriteResult::STATUS_BAD_REQUEST);
Expand All @@ -553,14 +553,14 @@ void TColumnShard::Handle(NEvents::TDataEvents::TEvWrite::TPtr& ev, const TActor

Counters.GetColumnTablesCounters()->GetPathIdCounter(pathId)->OnWriteEvent();

TMemoryProfileGuard mpg2("NEvents::TDataEvents::TEvWrite::Continue::0");
TMemoryProfileGuard mpg20("NEvents::TDataEvents::TEvWrite::Continue::0");
auto arrowData = std::make_shared<TArrowData>(schema);
if (!arrowData->Parse(operation, NEvWrite::TPayloadReader<NEvents::TDataEvents::TEvWrite>(*ev->Get()))) {
sendError("parsing data error", NKikimrDataEvents::TEvWriteResult::STATUS_BAD_REQUEST);
return;
}

TMemoryProfileGuard mpg2("NEvents::TDataEvents::TEvWrite::Continue::1");
TMemoryProfileGuard mpg21("NEvents::TDataEvents::TEvWrite::Continue::1");
auto overloadStatus = CheckOverloaded(pathId);
if (overloadStatus != EOverloadStatus::None) {
std::unique_ptr<NActors::IEventBase> result = NEvents::TDataEvents::TEvWriteResult::BuildError(
Expand All @@ -576,7 +576,7 @@ void TColumnShard::Handle(NEvents::TDataEvents::TEvWrite::TPtr& ev, const TActor
granuleShardingVersionId = record.GetGranuleShardingVersionId();
}

TMemoryProfileGuard mpg2("NEvents::TDataEvents::TEvWrite::Continue::2");
TMemoryProfileGuard mpg22("NEvents::TDataEvents::TEvWrite::Continue::2");
ui64 lockId = 0;
if (behaviour == EOperationBehaviour::NoTxWrite) {
lockId = BuildEphemeralTxId();
Expand Down

0 comments on commit 045abc1

Please sign in to comment.