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(locks.GetSendingShards().begin(), locks.GetSendingShards().end()); ReceivingShards = std::set(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();