Browse Source

fix dedup normalizer (#9849)

ivanmorozov333 5 months ago
parent
commit
06c6c6616b

+ 0 - 1
ydb/core/tx/columnshard/normalizer/insert_table/broken_dedup.cpp

@@ -93,7 +93,6 @@ TConclusion<std::vector<INormalizerTask::TPtr>> TInsertionsDedupNormalizer::DoIn
         if (constructor.GetRecType() == NColumnShard::Schema::EInsertTableIds::Committed) {
         if (constructor.GetRecType() == NColumnShard::Schema::EInsertTableIds::Committed) {
             AFL_VERIFY(constructor.GetPlanStep());
             AFL_VERIFY(constructor.GetPlanStep());
         } else {
         } else {
-            AFL_VERIFY(!constructor.GetPlanStep());
             if (constructor.GetRecType() == NColumnShard::Schema::EInsertTableIds::Aborted) {
             if (constructor.GetRecType() == NColumnShard::Schema::EInsertTableIds::Aborted) {
                 insertions[constructor.GetInsertWriteId()].SetAborted(constructor);
                 insertions[constructor.GetInsertWriteId()].SetAborted(constructor);
             } else if (constructor.GetRecType() == NColumnShard::Schema::EInsertTableIds::Inserted) {
             } else if (constructor.GetRecType() == NColumnShard::Schema::EInsertTableIds::Inserted) {