aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorIlnaz Nizametdinov <ilnaz@ydb.tech>2024-10-03 18:02:45 +0300
committerGitHub <noreply@github.com>2024-10-03 15:02:45 +0000
commit1a8906f19a717572fc39aa1265bb8c2ea7508eaa (patch)
tree8ab8ef71a062f20edb6eb59f453a8595df9e6d26
parent0e414edd1799095b87a3700199b2c8b53cb95088 (diff)
downloadydb-1a8906f19a717572fc39aa1265bb8c2ea7508eaa.tar.gz
Clear GonePartitions on every CreateSenders() (#10049)
-rw-r--r--ydb/core/change_exchange/change_sender.cpp4
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();
}