diff options
author | zverevgeny <zverevgeny@ydb.tech> | 2025-05-19 10:14:41 +0300 |
---|---|---|
committer | GitHub <noreply@github.com> | 2025-05-19 07:14:41 +0000 |
commit | 56f86176fd17ae36e1d0ce7a8bc7c274ee0dc937 (patch) | |
tree | 4f0cfeba26ae3567848821234f51adc89acc5f57 | |
parent | 891a10039d1dc269a351741d3f754fba826286f3 (diff) | |
download | ydb-56f86176fd17ae36e1d0ce7a8bc7c274ee0dc937.tar.gz |
Ignore unnecessary chunk normalizers (#18464)
-rw-r--r-- | ydb/core/tx/columnshard/normalizer/portion/restore_v1_chunks.cpp | 4 | ||||
-rw-r--r-- | ydb/core/tx/columnshard/normalizer/portion/restore_v2_chunks.cpp | 4 |
2 files changed, 6 insertions, 2 deletions
diff --git a/ydb/core/tx/columnshard/normalizer/portion/restore_v1_chunks.cpp b/ydb/core/tx/columnshard/normalizer/portion/restore_v1_chunks.cpp index 120b3451032..9cfdfde2193 100644 --- a/ydb/core/tx/columnshard/normalizer/portion/restore_v1_chunks.cpp +++ b/ydb/core/tx/columnshard/normalizer/portion/restore_v1_chunks.cpp @@ -210,8 +210,10 @@ TConclusion<std::vector<INormalizerTask::TPtr>> TNormalizer::DoInit( if (columns1Remove.empty() && portions0.empty()) { return tasks; } + if (!AppDataVerified().ColumnShardConfig.GetColumnChunksV0Usage()) { + return tasks; + } - AFL_VERIFY(AppDataVerified().ColumnShardConfig.GetColumnChunksV0Usage()); AFL_VERIFY(AppDataVerified().ColumnShardConfig.GetColumnChunksV1Usage()); { std::vector<TPatchItemRemoveV1> package; diff --git a/ydb/core/tx/columnshard/normalizer/portion/restore_v2_chunks.cpp b/ydb/core/tx/columnshard/normalizer/portion/restore_v2_chunks.cpp index bf9f470e8ec..33faac98063 100644 --- a/ydb/core/tx/columnshard/normalizer/portion/restore_v2_chunks.cpp +++ b/ydb/core/tx/columnshard/normalizer/portion/restore_v2_chunks.cpp @@ -170,7 +170,9 @@ TConclusion<std::vector<INormalizerTask::TPtr>> TNormalizer::DoInit( if (buildPortions.empty()) { return tasks; } - AFL_VERIFY(AppDataVerified().ColumnShardConfig.GetColumnChunksV1Usage()); + if (!AppDataVerified().ColumnShardConfig.GetColumnChunksV1Usage()) { + return tasks; + } { std::vector<TV2BuildTask> package; |