Skip to content

Commit 10580ef

Browse files
authored
fixed possible memory travel (#16016)
1 parent e5b26c3 commit 10580ef

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

ydb/core/persqueue/read_balancer__balancing.cpp

+3-2
Original file line numberDiff line numberDiff line change
@@ -1079,13 +1079,14 @@ bool TConsumer::ProccessReadingFinished(ui32 partitionId, bool wasInactive, cons
10791079

10801080
void TConsumer::StartReading(ui32 partitionId, const TActorContext& ctx) {
10811081
if (!GetPartitionInfo(partitionId)) {
1082-
PQ_LOG_CRIT("start reading for deleted partition " << partitionId);
1082+
PQ_LOG_NOTICE("Reading of the partition " << partitionId << " was started by " << ConsumerName << " but partition has been deleted.");
10831083
return;
10841084
}
10851085

10861086
auto* partition = GetPartition(partitionId);
10871087
if (!partition) {
1088-
PQ_LOG_D("Reading of the partition " << partitionId << " was started by " << ConsumerName << ".");
1088+
PQ_LOG_NOTICE("Reading of the partition " << partitionId << " was started by " << ConsumerName << " but partition does not exist.");
1089+
return;
10891090
}
10901091

10911092
auto wasInactive = partition->IsInactive();

0 commit comments

Comments
 (0)