aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorkungurtsev <kungasc@ydb.tech>2023-12-22 11:33:46 +0100
committerGitHub <noreply@github.com>2023-12-22 11:33:46 +0100
commit145901833ba639ef66ed095644a6b81994493c7a (patch)
tree886bfef6dbe2e75b5124fb9fdaf1e4fca0df809c
parent228b08549a4b7218d00893cfde60acca03b3fb81 (diff)
downloadydb-145901833ba639ef66ed095644a6b81994493c7a.tar.gz
KIKIMR-19139 Bugfix load indexes (#657)
-rw-r--r--ydb/core/tablet_flat/flat_scan_feed.h16
1 files changed, 10 insertions, 6 deletions
diff --git a/ydb/core/tablet_flat/flat_scan_feed.h b/ydb/core/tablet_flat/flat_scan_feed.h
index 56e8f1629f..6535700c01 100644
--- a/ydb/core/tablet_flat/flat_scan_feed.h
+++ b/ydb/core/tablet_flat/flat_scan_feed.h
@@ -359,12 +359,16 @@ namespace NTable {
bool LoadIndexes() noexcept
{
bool ready = true;
- for (const auto& partView : Subset.Flatten) {
- for (auto indexPageId : partView->IndexPages.Groups) {
- ready &= bool(CurrentEnv->TryGetPage(partView.Part.Get(), indexPageId));
- }
- for (auto indexPageId : partView->IndexPages.Historic) {
- ready &= bool(CurrentEnv->TryGetPage(partView.Part.Get(), indexPageId));
+ if (Levels) {
+ for (const auto &run: *Levels) {
+ for (const auto &item : run) {
+ for (auto indexPageId : item.Part->IndexPages.Groups) {
+ ready &= bool(CurrentEnv->TryGetPage(item.Part.Get(), indexPageId));
+ }
+ for (auto indexPageId : item.Part->IndexPages.Historic) {
+ ready &= bool(CurrentEnv->TryGetPage(item.Part.Get(), indexPageId));
+ }
+ }
}
}
return ready;