Removed LastSendedNextMessageOffset

Author: GrigoriyPA

ydb/core/fq/libs/row_dispatcher/events/topic_session_stats.h

@@ -15,7 +15,6 @@ struct TTopicSessionClientStatistic {
     bool IsWaiting = false;     // Current value
     i64 ReadLagMessages = 0;    // Current value
     ui64 InitialOffset = 0;
-    ui64 LastSendedNextMessageOffset = 0;
     void Add(const TTopicSessionClientStatistic& stat) {
         UnreadRows = stat.UnreadRows;
         UnreadBytes = stat.UnreadBytes;
@@ -24,7 +23,6 @@ struct TTopicSessionClientStatistic {
         IsWaiting = stat.IsWaiting;
         ReadLagMessages = stat.ReadLagMessages;
         InitialOffset = stat.InitialOffset;
-        LastSendedNextMessageOffset = stat.LastSendedNextMessageOffset;
     }
     void Clear() {
         ReadBytes = 0;

ydb/core/fq/libs/row_dispatcher/row_dispatcher.cpp

@@ -681,7 +681,6 @@ TString TRowDispatcher::GetInternalState() {
                 str << "    " << consumer->QueryId << " " << LeftPad(readActorId, 32) << " unread bytes "
                     << toHuman(consumer->Stat.UnreadBytes) << " (" << leftPad(consumer->Stat.UnreadRows) << " rows) "
                     << " offset " << leftPad(consumer->Stat.Offset) << " init offset " << leftPad(consumer->Stat.InitialOffset)
-                    << " last send offset " << leftPad(consumer->Stat.LastSendedNextMessageOffset)
                     << " get " << leftPad(consumer->Counters.GetNextBatch)
                     << " arr " << leftPad(consumer->Counters.NewDataArrived) << " btc " << leftPad(consumer->Counters.MessageBatch) 
                     << " pend get " <<  leftPad(consumer->PendingGetNextBatch) << " pend new " << leftPad(consumer->PendingNewDataArrived)

ydb/core/fq/libs/row_dispatcher/topic_session.cpp

@@ -181,7 +181,6 @@ class TTopicSession : public TActorBootstrapped<TTopicSession> {
 
         // Metrics
         ui64 InitialOffset = 0;
-        ui64 LastSendedNextMessageOffset = 0;
         TStats Stat;        // Send (filtered) to read_actor
         NMonitoring::TDynamicCounters::TCounterPtr FilteredDataRate;    // filtered
         NMonitoring::TDynamicCounters::TCounterPtr RestartSessionByOffsetsByQuery;
@@ -488,7 +487,6 @@ void TTopicSession::Handle(NFq::TEvPrivate::TEvSendStatisticToReadActor::TPtr&)
         event->Record.SetPartitionId(PartitionId);
         event->Record.SetNextMessageOffset(*info.NextMessageOffset);
         event->Record.SetReadBytes(readBytes);
-        info.LastSendedNextMessageOffset = *info.NextMessageOffset;
         event->ReadActorId = info.ReadActorId;
         LOG_ROW_DISPATCHER_TRACE("Send status to " << info.ReadActorId << ", offset " << *info.NextMessageOffset);
         Send(RowDispatcherActorId, event.release());
@@ -672,7 +670,6 @@ void TTopicSession::SendData(TClientsInfo& info) {
 
     info.Stat.Add(dataSize, eventsSize);
     info.FilteredDataRate->Add(dataSize);
-    info.LastSendedNextMessageOffset = *info.NextMessageOffset;
 }
 
 void TTopicSession::StartClientSession(TClientsInfo& info) {
@@ -819,7 +816,6 @@ void TTopicSession::SendStatisticToRowDispatcher() {
         clientStatistic.IsWaiting = LastMessageOffset + 1 < info.NextMessageOffset.GetOrElse(0);
         clientStatistic.ReadLagMessages = info.NextMessageOffset.GetOrElse(0) - LastMessageOffset - 1;
         clientStatistic.InitialOffset = info.InitialOffset;
-        clientStatistic.LastSendedNextMessageOffset = info.LastSendedNextMessageOffset;
         info.Stat.Clear();
         sessionStatistic.Clients.emplace_back(std::move(clientStatistic));
     }