diff options
| author | Artem Alekseev <fexolm@ydb.tech> | 2024-11-20 20:05:26 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-11-20 20:05:26 +0300 |
| commit | 872bb4d25b2454e82c5bbc045690c97cb64846ab (patch) | |
| tree | 024f35381b6a8e8f60f67863f3a77239e2010059 | |
| parent | 4644e090d713dd56dd5734b49ad80400f1a21414 (diff) | |
| download | ydb-872bb4d25b2454e82c5bbc045690c97cb64846ab.tar.gz | |
Add portion_id to log scope in TReadPortionInfoWithBlobs::RestoreBatch (#11771)
| -rw-r--r-- | ydb/core/tx/columnshard/engines/portions/read_with_blobs.cpp | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/ydb/core/tx/columnshard/engines/portions/read_with_blobs.cpp b/ydb/core/tx/columnshard/engines/portions/read_with_blobs.cpp index 949444bd4b..38889cbefe 100644 --- a/ydb/core/tx/columnshard/engines/portions/read_with_blobs.cpp +++ b/ydb/core/tx/columnshard/engines/portions/read_with_blobs.cpp @@ -18,6 +18,8 @@ void TReadPortionInfoWithBlobs::RestoreChunk(const std::shared_ptr<IPortionDataC TConclusion<std::shared_ptr<NArrow::TGeneralContainer>> TReadPortionInfoWithBlobs::RestoreBatch( const ISnapshotSchema& data, const ISnapshotSchema& resultSchema, const std::set<ui32>& seqColumns) const { THashMap<TChunkAddress, TString> blobs; + NActors::TLogContextGuard gLogging = + NActors::TLogContextBuilder::Build(NKikimrServices::TX_COLUMNSHARD)("portion_id", PortionInfo.GetPortionInfo().GetPortionId()); for (auto&& i : PortionInfo.GetRecordsVerified()) { blobs[i.GetAddress()] = GetBlobByAddressVerified(i.ColumnId, i.Chunk); Y_ABORT_UNLESS(blobs[i.GetAddress()].size() == i.BlobRange.Size); |