diff options
author | alexvru <alexvru@ydb.tech> | 2023-12-15 14:40:42 +0300 |
---|---|---|
committer | alexvru <alexvru@ydb.tech> | 2023-12-15 17:07:17 +0300 |
commit | 9a66e848f06cac29bb487bd482e48130c1648804 (patch) | |
tree | ca064345d544cc196ef234e76917ddfaca8aab00 | |
parent | d7b919c409ed0a2fc4365f0156de411029bb314e (diff) | |
download | ydb-9a66e848f06cac29bb487bd482e48130c1648804.tar.gz |
Fix channel garbage collection issue KIKIMR-20525
-rw-r--r-- | ydb/core/blob_depot/data_load.cpp | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/ydb/core/blob_depot/data_load.cpp b/ydb/core/blob_depot/data_load.cpp index 23fd922f73..8cec6e3f57 100644 --- a/ydb/core/blob_depot/data_load.cpp +++ b/ydb/core/blob_depot/data_load.cpp @@ -77,8 +77,13 @@ namespace NKikimr::NBlobDepot { // prepare records for all groups in history for (const auto& channel : Self->Info()->Channels) { + Y_ABORT_UNLESS(channel.Channel < Self->Channels.size()); + if (Self->Channels[channel.Channel].ChannelKind != NKikimrBlobDepot::TChannelKind::Data) { + continue; // skip non-data channels + } for (const auto& entry : channel.History) { - RecordsPerChannelGroup.try_emplace(std::make_tuple(channel.Channel, entry.GroupID), channel.Channel, entry.GroupID); + RecordsPerChannelGroup.try_emplace(std::make_tuple(channel.Channel, entry.GroupID), channel.Channel, + entry.GroupID); } } |