Skip to content

Commit b1035b0

Browse files
zverevgenynshestakov
authored andcommitted
Ignore unnecessary chunk normalizers (ydb-platform#18464)
1 parent 2e1b061 commit b1035b0

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

ydb/core/tx/columnshard/normalizer/portion/restore_v1_chunks.cpp

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -210,8 +210,10 @@ TConclusion<std::vector<INormalizerTask::TPtr>> TNormalizer::DoInit(
210210
if (columns1Remove.empty() && portions0.empty()) {
211211
return tasks;
212212
}
213+
if (!AppDataVerified().ColumnShardConfig.GetColumnChunksV0Usage()) {
214+
return tasks;
215+
}
213216

214-
AFL_VERIFY(AppDataVerified().ColumnShardConfig.GetColumnChunksV0Usage());
215217
AFL_VERIFY(AppDataVerified().ColumnShardConfig.GetColumnChunksV1Usage());
216218
{
217219
std::vector<TPatchItemRemoveV1> package;

ydb/core/tx/columnshard/normalizer/portion/restore_v2_chunks.cpp

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -170,7 +170,9 @@ TConclusion<std::vector<INormalizerTask::TPtr>> TNormalizer::DoInit(
170170
if (buildPortions.empty()) {
171171
return tasks;
172172
}
173-
AFL_VERIFY(AppDataVerified().ColumnShardConfig.GetColumnChunksV1Usage());
173+
if (!AppDataVerified().ColumnShardConfig.GetColumnChunksV1Usage()) {
174+
return tasks;
175+
}
174176

175177
{
176178
std::vector<TV2BuildTask> package;

0 commit comments

Comments
 (0)