Skip to content

Commit 2926706

Browse files
[-] the value of PartitionsInited should not change for service partitions
1 parent 03cdddc commit 2926706

File tree

1 file changed

+10
-3
lines changed

1 file changed

+10
-3
lines changed

ydb/core/persqueue/pq_impl.cpp

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1506,9 +1506,10 @@ void TPersQueue::Handle(TEvPQ::TEvInitComplete::TPtr& ev, const TActorContext& c
15061506
ctx);
15071507
}
15081508
partition.PendingRequests.clear();
1509+
} else {
1510+
++PartitionsInited;
15091511
}
15101512

1511-
++PartitionsInited;
15121513
Y_ABORT_UNLESS(ConfigInited);//partitions are inited only after config
15131514

15141515
auto allInitialized = AllOriginalPartitionsInited();
@@ -1907,11 +1908,17 @@ void TPersQueue::ProcessStatusRequests(const TActorContext &ctx) {
19071908

19081909
void TPersQueue::Handle(TEvPersQueue::TEvStatus::TPtr& ev, const TActorContext& ctx)
19091910
{
1911+
PQ_LOG_D("Handle TEvPersQueue::TEvStatus");
1912+
19101913
ReadBalancerActorId = ev->Sender;
19111914

19121915
if (!ConfigInited || !AllOriginalPartitionsInited()) {
1913-
StatusRequests.push_back(ev);
1914-
return;
1916+
PQ_LOG_D("Postpone the request." <<
1917+
" ConfigInited " << static_cast<int>(ConfigInited) <<
1918+
", PartitionsInited " << PartitionsInited <<
1919+
", OriginalPartitionsCount " << OriginalPartitionsCount);
1920+
StatusRequests.push_back(ev);
1921+
return;
19151922
}
19161923

19171924
ui32 cnt = 0;

0 commit comments

Comments
 (0)