aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoralexvru <alexvru@ydb.tech>2023-12-15 14:40:42 +0300
committeralexvru <alexvru@ydb.tech>2023-12-15 17:07:17 +0300
commit9a66e848f06cac29bb487bd482e48130c1648804 (patch)
treeca064345d544cc196ef234e76917ddfaca8aab00
parentd7b919c409ed0a2fc4365f0156de411029bb314e (diff)
downloadydb-9a66e848f06cac29bb487bd482e48130c1648804.tar.gz
Fix channel garbage collection issue KIKIMR-20525
-rw-r--r--ydb/core/blob_depot/data_load.cpp7
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);
}
}