Skip to content

Commit 3624119

Browse files
authored
fixed CDC write to the autopartitioning topic (#20242)
2 parents 941f9c7 + 53e9a69 commit 3624119

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

ydb/core/tx/datashard/change_exchange_split.cpp

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -360,6 +360,10 @@ class TCdcWorker
360360
const auto partitionId = partition.GetPartitionId();
361361
const auto tabletId = partition.GetTabletId();
362362

363+
if (NKikimrPQ::ETopicPartitionStatus::Active != partition.GetStatus()) {
364+
continue;
365+
}
366+
363367
auto it = Workers.find(partitionId);
364368
if (it != Workers.end()) {
365369
workers.emplace(partitionId, it->second);

0 commit comments

Comments
 (0)