aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorzverevgeny <zverevgeny@ydb.tech>2025-05-19 10:14:41 +0300
committerGitHub <noreply@github.com>2025-05-19 07:14:41 +0000
commit56f86176fd17ae36e1d0ce7a8bc7c274ee0dc937 (patch)
tree4f0cfeba26ae3567848821234f51adc89acc5f57
parent891a10039d1dc269a351741d3f754fba826286f3 (diff)
downloadydb-56f86176fd17ae36e1d0ce7a8bc7c274ee0dc937.tar.gz
Ignore unnecessary chunk normalizers (#18464)
-rw-r--r--ydb/core/tx/columnshard/normalizer/portion/restore_v1_chunks.cpp4
-rw-r--r--ydb/core/tx/columnshard/normalizer/portion/restore_v2_chunks.cpp4
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;