diff options
| author | Ilnaz Nizametdinov <ilnaz@ydb.tech> | 2024-10-03 18:02:45 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-10-03 15:02:45 +0000 |
| commit | 1a8906f19a717572fc39aa1265bb8c2ea7508eaa (patch) | |
| tree | 8ab8ef71a062f20edb6eb59f453a8595df9e6d26 | |
| parent | 0e414edd1799095b87a3700199b2c8b53cb95088 (diff) | |
| download | ydb-1a8906f19a717572fc39aa1265bb8c2ea7508eaa.tar.gz | |
Clear GonePartitions on every CreateSenders() (#10049)
| -rw-r--r-- | ydb/core/change_exchange/change_sender.cpp | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/ydb/core/change_exchange/change_sender.cpp b/ydb/core/change_exchange/change_sender.cpp index df2de3ebf8..f8a3116840 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<ui64>& partitionIds) { if (partitionIds) { CreateMissingSenders(partitionIds); } else { - RecreateSenders(std::exchange(GonePartitions, {})); + RecreateSenders(GonePartitions); } + GonePartitions.clear(); + if (!Enqueued || !RequestRecords()) { SendRecords(); } |