fix compaction policy modification (#12384)

Author: ivanmorozov333

ydb/core/tx/columnshard/engines/storage/optimizer/lcbuckets/constructor/constructor.cpp

@@ -18,6 +18,14 @@ bool TOptimizerPlannerConstructor::DoApplyToCurrentObject(IOptimizerPlanner& cur
 bool TOptimizerPlannerConstructor::DoIsEqualTo(const IOptimizerPlannerConstructor& item) const {
     const auto* itemClass = dynamic_cast<const TOptimizerPlannerConstructor*>(&item);
     AFL_VERIFY(itemClass);
+    if (Levels.size() != itemClass->Levels.size()) {
+        return false;
+    }
+    for (ui32 i = 0; i < Levels.size(); ++i) {
+        if (!Levels[i]->IsEqualTo(*itemClass->Levels[i].GetObjectPtrVerified())) {
+            return false;
+        }
+    }
     return true;
 }
 
@@ -61,8 +69,8 @@ NKikimr::TConclusionStatus TOptimizerPlannerConstructor::DoDeserializeFromJson(c
         if (!level) {
             return TConclusionStatus::Fail("incorrect level class_name: " + className);
         }
-        if (!level->DeserializeFromJson(i["description"])) {
-            return TConclusionStatus::Fail("cannot parse level: " + className + ": " + i["description"].GetStringRobust());
+        if (!level->DeserializeFromJson(i)) {
+            return TConclusionStatus::Fail("cannot parse level: " + i.GetStringRobust());
         }
         Levels.emplace_back(TLevelConstructorContainer(std::shared_ptr<ILevelConstructor>(level.Release())));
     }

ydb/core/tx/columnshard/engines/storage/optimizer/lcbuckets/constructor/constructor.h

@@ -12,13 +12,21 @@ class ILevelConstructor {
     virtual TConclusionStatus DoDeserializeFromJson(const NJson::TJsonValue& json) = 0;
     virtual bool DoDeserializeFromProto(const NKikimrSchemeOp::TCompactionLevelConstructorContainer& proto) = 0;
     virtual void DoSerializeToProto(NKikimrSchemeOp::TCompactionLevelConstructorContainer& proto) const = 0;
+    virtual bool IsEqualToSameClass(const ILevelConstructor& item) const = 0;
 
 public:
     using TFactory = NObjectFactory::TObjectFactory<ILevelConstructor, TString>;
     using TProto = NKikimrSchemeOp::TCompactionLevelConstructorContainer;
 
     virtual ~ILevelConstructor() = default;
 
+    bool IsEqualTo(const ILevelConstructor& item) const {
+        if (GetClassName() != item.GetClassName()) {
+            return false;
+        }
+        return IsEqualToSameClass(item);
+    }
+
     std::shared_ptr<IPortionsLevel> BuildLevel(
         const std::shared_ptr<IPortionsLevel>& nextLevel, const ui32 indexLevel, const TLevelCounters& counters) const {
         return DoBuildLevel(nextLevel, indexLevel, counters);

ydb/core/tx/columnshard/engines/storage/optimizer/lcbuckets/constructor/zero_level.cpp

@@ -5,6 +5,9 @@
 namespace NKikimr::NOlap::NStorageOptimizer::NLCBuckets {
 
 TConclusionStatus TZeroLevelConstructor::DoDeserializeFromJson(const NJson::TJsonValue& json) {
+    if (!json.IsMap()) {
+        return TConclusionStatus::Fail("incorrect level description");
+    }
     if (json.Has("portions_live_duration")) {
         const auto& jsonValue = json["portions_live_duration"];
         if (!jsonValue.IsString()) {

ydb/core/tx/columnshard/engines/storage/optimizer/lcbuckets/constructor/zero_level.h

@@ -18,6 +18,10 @@ class TZeroLevelConstructor: public ILevelConstructor {
     virtual TConclusionStatus DoDeserializeFromJson(const NJson::TJsonValue& json) override;
     virtual bool DoDeserializeFromProto(const NKikimrSchemeOp::TCompactionLevelConstructorContainer& proto) override;
     virtual void DoSerializeToProto(NKikimrSchemeOp::TCompactionLevelConstructorContainer& proto) const override;
+    virtual bool IsEqualToSameClass(const ILevelConstructor& item) const override {
+        const auto& itemCast = dynamic_cast<const TZeroLevelConstructor&>(item);
+        return PortionsLiveDuration == itemCast.PortionsLiveDuration && ExpectedBlobsSize == itemCast.ExpectedBlobsSize;
+    }
 
     static const inline TFactory::TRegistrator<TZeroLevelConstructor> Registrator = TFactory::TRegistrator<TZeroLevelConstructor>(GetClassNameStatic());