Merge 7199d82 into afbc266

ivanmorozov333 · web-flow · commit 68a5c8d65fdd · 2024-11-25T12:34:38.000+03:00
diff --git a/ydb/core/tx/columnshard/engines/storage/actualizer/tiering/tiering.cpp b/ydb/core/tx/columnshard/engines/storage/actualizer/tiering/tiering.cpp
@@ -88,7 +88,7 @@ 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);

Original file line number	Diff line number	Diff line change
`@@ -88,7 +88,7 @@ void TTieringActualizer::DoAddPortion(const TPortionInfo& portion, const TAddExt`
`88`	`88`	`AFL_VERIFY(!PortionsInfo.contains(portion.GetPortionId()))("id", portion.GetPortionId())("path_id", portion.GetPathId());`
`89`	`89`	`AFL_VERIFY(!NewPortionIds.contains(portion.GetPortionId()))("id", portion.GetPortionId())("path_id", portion.GetPathId());`
`90`	`90`	`}`
`91`		`- if (MaxByPortionId.contains(portion.GetPortionId())) {`
	`91`	`+ if (!Tiering \|\| MaxByPortionId.contains(portion.GetPortionId())) {`
`92`	`92`	`AddPortionImpl(portion, addContext.GetNow());`
`93`	`93`	`} else {`
`94`	`94`	`auto schema = portion.GetSchema(VersionedIndex);`