Skip to content

Commit

Permalink
[/] broken tests
Browse files Browse the repository at this point in the history
  • Loading branch information
Alek5andr-Kotov committed Feb 6, 2025
1 parent b517e84 commit 28a1f28
Showing 1 changed file with 4 additions and 3 deletions.
7 changes: 4 additions & 3 deletions ydb/core/persqueue/pq_l2_cache.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -173,12 +173,13 @@ void TPersQueueCacheL2::RenameBlobs(const TActorContext& ctx, ui64 tabletId,
for (const auto& [oldBlob, newBlob] : blobs) {
TKey oldKey(tabletId, oldBlob);
auto it = Cache.FindWithoutPromote(oldKey);
if (it != Cache.End()) {
Cache.Erase(it);
if (it == Cache.End()) {
continue;
}

TKey newKey(tabletId, newBlob);
Cache.Insert(newKey, newBlob.Value);
Cache.Insert(newKey, *it);
Cache.Erase(it);

LOG_DEBUG_S(ctx, NKikimrServices::PERSQUEUE, "PQ Cache (L2). Renamed. Tablet '" << tabletId
<< "' old partition " << oldBlob.Partition << " old offset " << oldBlob.Offset
Expand Down

0 comments on commit 28a1f28

Please sign in to comment.