Skip to content

Commit 5f2c357

Browse files
provide correct path id to lock info (#8591)
1 parent 68720d1 commit 5f2c357

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

ydb/core/tx/columnshard/blobs_action/transaction/tx_write.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -109,6 +109,7 @@ bool TTxWrite::Execute(TTransactionContext& txc, const TActorContext&) {
109109
lock.SetDataShard(Self->TabletID());
110110
lock.SetGeneration(info.GetGeneration());
111111
lock.SetCounter(info.GetInternalGenerationCounter());
112+
lock.SetPathId(writeMeta.GetTableId());
112113
auto ev = NEvents::TDataEvents::TEvWriteResult::BuildCompleted(Self->TabletID(), operation->GetLockId(), lock);
113114
Results.emplace_back(std::move(ev), writeMeta.GetSource(), operation->GetCookie());
114115
}

ydb/core/tx/columnshard/engines/reader/plain_reader/constructor/read_metadata.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,7 @@ void TReadMetadata::DoOnReplyConstruction(const ui64 tabletId, NKqp::NInternalIm
109109
lockInfo.SetGeneration(LockSharingInfo->GetGeneration());
110110
lockInfo.SetDataShard(tabletId);
111111
lockInfo.SetCounter(LockSharingInfo->GetCounter());
112-
// lockInfo.SetPathId(PathId);
112+
lockInfo.SetPathId(PathId);
113113
lockInfo.SetHasWrites(LockSharingInfo->HasWrites());
114114
if (LockSharingInfo->IsBroken()) {
115115
scanData.LocksInfo.BrokenLocks.emplace_back(std::move(lockInfo));

0 commit comments

Comments
 (0)