LOGBROKER-8894 enable minSeqNo save in partition #1654
Conversation
|
⚪
|
|
⚪
|
| @@ -327,13 +327,13 @@ void TPartition::AnswerCurrentWrites(const TActorContext& ctx) { | |||
| if (it == SourceIdStorage.GetInMemorySourceIds().end()) { | |||
| Y_ABORT_UNLESS(!writeResponse.Msg.HeartbeatVersion); | |||
| TabletCounters.Cumulative()[COUNTER_PQ_SID_CREATED].Increment(1); | |||
| SourceIdStorage.RegisterSourceId(s, seqNo, offset, CurrentTimestamp); | |||
| SourceIdStorage.RegisterSourceId(s, seqNo, 0, offset, CurrentTimestamp); | |||
There was a problem hiding this comment.
Я правильно понимаю, что это первая операция записи для неизвестного SourceId? Если это так, то MinSeqNo должно быть равно seqNo
ydb/core/persqueue/sourceid.cpp
Outdated
| auto copy = *this; | ||
| copy.SeqNo = seqNo; | ||
| if (minSeqNo) { | ||
| copy.MinSeqNo = minSeqNo; | ||
| } |
There was a problem hiding this comment.
А здесь должно быть MinSeqNo? Оно сохраняется один раз при первой операции записи и не меняется.
There was a problem hiding this comment.
Это на случай, если оно нулём инициализировано, а потом у нас через это копирование Update происходит.
|
⚪
|
|
⚪
|
No description provided.