Skip to content

Commit 1a8906f

Browse files
authored
Clear GonePartitions on every CreateSenders() (#10049)
1 parent 0e414ed commit 1a8906f

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

ydb/core/change_exchange/change_sender.cpp

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,9 +65,11 @@ void TChangeSender::CreateSendersImpl(const TVector<ui64>& partitionIds) {
6565
if (partitionIds) {
6666
CreateMissingSenders(partitionIds);
6767
} else {
68-
RecreateSenders(std::exchange(GonePartitions, {}));
68+
RecreateSenders(GonePartitions);
6969
}
7070

71+
GonePartitions.clear();
72+
7173
if (!Enqueued || !RequestRecords()) {
7274
SendRecords();
7375
}

0 commit comments

Comments
 (0)