correct

Author: ivanmorozov333

ydb/core/tx/columnshard/columnshard__write.cpp

@@ -313,6 +313,9 @@ class TCommitOperation {
         auto& lock = evWrite.Record.GetLocks().GetLocks()[0];
         SendingShards = std::set<ui64>(locks.GetSendingShards().begin(), locks.GetSendingShards().end());
         ReceivingShards = std::set<ui64>(locks.GetReceivingShards().begin(), locks.GetReceivingShards().end());
+        if (SendingShards.empty() != ReceivingShards.empty()) {
+            return TConclusionStatus::Fail("incorrect synchronization data (send/receiving lists)");
+        }
         if (ReceivingShards.size() && SendingShards.size()) {
             if (!locks.HasArbiterColumnShard()) {
                 ArbiterColumnShard = *ReceivingShards.begin();
@@ -326,8 +329,6 @@ class TCommitOperation {
                     return TConclusionStatus::Fail("shard is incorrect for sending/receiving lists");
                 }
             }
-        } else {
-            AFL_VERIFY(!SendingShards.size() && !ReceivingShards.size());
         }
 
         TxId = evWrite.Record.GetTxId();