From b8b8174511fd107de3f718cf5e3850c030c24f06 Mon Sep 17 00:00:00 2001
From: ivanmorozov333 <ivanmorozov@hotmail.com>
Date: Tue, 7 Jan 2025 15:17:17 +0300
Subject: [PATCH] correct

---
 ydb/core/tx/columnshard/columnshard__write.cpp | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/ydb/core/tx/columnshard/columnshard__write.cpp b/ydb/core/tx/columnshard/columnshard__write.cpp
index 18b1a2b0cfa4..0a020929c200 100644
--- 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();