diff options
| author | ivanmorozov333 <ivanmorozov@ydb.tech> | 2024-11-25 13:50:25 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-11-25 10:50:25 +0000 |
| commit | 346aedca9e388acf1b1de44416081aabea462026 (patch) | |
| tree | 093c9bab85fdbea1f499c4cd0fedf9317336afc0 | |
| parent | 199d47d2f2c5da95681170e1b97e1784602a6e81 (diff) | |
| download | ydb-346aedca9e388acf1b1de44416081aabea462026.tar.gz | |
fix empty variable usage (#11926)
| -rw-r--r-- | ydb/core/tx/columnshard/engines/storage/actualizer/tiering/tiering.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/ydb/core/tx/columnshard/engines/storage/actualizer/tiering/tiering.cpp b/ydb/core/tx/columnshard/engines/storage/actualizer/tiering/tiering.cpp index 6026b9e2de..b63cd5cf4c 100644 --- a/ydb/core/tx/columnshard/engines/storage/actualizer/tiering/tiering.cpp +++ b/ydb/core/tx/columnshard/engines/storage/actualizer/tiering/tiering.cpp @@ -88,11 +88,11 @@ void TTieringActualizer::DoAddPortion(const TPortionInfo& portion, const TAddExt AFL_VERIFY(!PortionsInfo.contains(portion.GetPortionId()))("id", portion.GetPortionId())("path_id", portion.GetPathId()); AFL_VERIFY(!NewPortionIds.contains(portion.GetPortionId()))("id", portion.GetPortionId())("path_id", portion.GetPathId()); } - if (MaxByPortionId.contains(portion.GetPortionId())) { + if (!Tiering || MaxByPortionId.contains(portion.GetPortionId())) { AddPortionImpl(portion, addContext.GetNow()); } else { auto schema = portion.GetSchema(VersionedIndex); - if (*TieringColumnId == schema->GetIndexInfo().GetPKColumnIds().front()) { + if (*TValidator::CheckNotNull(TieringColumnId) == schema->GetIndexInfo().GetPKColumnIds().front()) { NYDBTest::TControllers::GetColumnShardController()->OnMaxValueUsage(); auto max = NArrow::TStatusValidator::GetValid(portion.GetMeta().GetFirstLastPK().GetFirst().Column(0).GetScalar(0)); AFL_VERIFY(MaxByPortionId.emplace(portion.GetPortionId(), max).second); |