diff --git a/ydb/core/change_exchange/change_sender.cpp b/ydb/core/change_exchange/change_sender.cpp index df2de3ebf800..f8a3116840c2 100644 --- a/ydb/core/change_exchange/change_sender.cpp +++ b/ydb/core/change_exchange/change_sender.cpp @@ -65,9 +65,11 @@ void TChangeSender::CreateSendersImpl(const TVector& partitionIds) { if (partitionIds) { CreateMissingSenders(partitionIds); } else { - RecreateSenders(std::exchange(GonePartitions, {})); + RecreateSenders(GonePartitions); } + GonePartitions.clear(); + if (!Enqueued || !RequestRecords()) { SendRecords(); }