Merge 1553851 into 22dd11e

Author: ivanmorozov333

ydb/core/tx/columnshard/engines/changes/indexation.cpp

@@ -230,6 +230,7 @@ TConclusionStatus TInsertColumnEngineChanges::DoConstructBlobs(TConstructionCont
         }
         pathBatches.AddChunkInfo(inserted, context);
     }
+    NoAppendIsCorrect = pathBatches.GetData().empty();
 
     pathBatches.FinishChunksInfo();
 

ydb/core/tx/columnshard/engines/changes/with_appended.cpp

@@ -119,7 +119,7 @@ void TChangesWithAppend::DoWriteIndexOnComplete(NColumnShard::TColumnShard* self
 }
 
 void TChangesWithAppend::DoCompile(TFinalizationContext& context) {
-    AFL_VERIFY(PortionsToRemove.size() + PortionsToMove.size() + AppendedPortions.size());
+    AFL_VERIFY(PortionsToRemove.size() + PortionsToMove.size() + AppendedPortions.size() || NoAppendIsCorrect);
     for (auto&& i : AppendedPortions) {
         i.GetPortionConstructor().MutablePortionConstructor().SetPortionId(context.NextPortionId());
         i.GetPortionConstructor().MutablePortionConstructor().MutableMeta().SetCompactionLevel(TargetCompactionLevel.value_or(0));

ydb/core/tx/columnshard/engines/changes/with_appended.h

@@ -15,6 +15,9 @@ class TChangesWithAppend: public TColumnEngineChanges {
 protected:
     std::optional<ui64> TargetCompactionLevel;
     TSaverContext SaverContext;
+    bool NoAppendIsCorrect = false;
+    std::vector<TWritePortionInfoWithBlobsResult> AppendedPortions;
+
     virtual void OnDataAccessorsInitialized(const TDataAccessorsInitializationContext& /*context*/) override {
 
     }
@@ -90,7 +93,6 @@ class TChangesWithAppend: public TColumnEngineChanges {
         }
     }
 
-    std::vector<TWritePortionInfoWithBlobsResult> AppendedPortions;
     virtual ui32 GetWritePortionsCount() const override {
         return AppendedPortions.size();
     }