correct

ydb-platform · Jan 7, 2025 · b8b8174 · b8b8174
1 parent aaf6aae
commit b8b8174
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/ydb/core/tx/columnshard/columnshard__write.cpp b/ydb/core/tx/columnshard/columnshard__write.cpp
@@ -313,8 +313,7 @@ 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 (ReceivingShards.size()) {
-            AFL_VERIFY(SendingShards.size());
+        if (ReceivingShards.size() && SendingShards.size()) {
             if (!locks.HasArbiterColumnShard()) {
                 ArbiterColumnShard = *ReceivingShards.begin();
                 if (!ReceivingShards.contains(TabletId) && !SendingShards.contains(TabletId)) {
@@ -328,7 +327,7 @@ class TCommitOperation {
                 }
             }
         } else {
-            AFL_VERIFY(!SendingShards.size());
+            AFL_VERIFY(!SendingShards.size() && !ReceivingShards.size());
         }
 
         TxId = evWrite.Record.GetTxId();