Skip to content

Commit 142b531

Browse files
authored
Fix frozen write sessions which wait reserve bytes (#7530)
1 parent 7ad9e1e commit 142b531

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

ydb/core/persqueue/partition_write.cpp

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -166,6 +166,12 @@ void TPartition::ProcessReserveRequests(const TActorContext& ctx) {
166166
const ui64& cookie = ReserveRequests.front()->Cookie;
167167
const bool& lastRequest = ReserveRequests.front()->LastRequest;
168168

169+
if (!IsActive()) {
170+
ReplyOk(ctx, cookie);
171+
ReserveRequests.pop_front();
172+
continue;
173+
}
174+
169175
auto it = Owners.find(owner);
170176
if (ClosedInternalPartition) {
171177
ReplyError(ctx, cookie, NPersQueue::NErrorCode::BAD_REQUEST, "ReserveRequest to closed supportive partition");

0 commit comments

Comments
 (0)