File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
ydb/core/fq/libs/row_dispatcher Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -600,7 +600,7 @@ void TRowDispatcher::UpdateMetrics() {
600600 if (partionIt == consumer->Partitions .end ()) {
601601 continue ;
602602 }
603- const auto & partition = partionIt->second ;
603+ auto & partition = partionIt->second ;
604604 auto & stat = AggrStats.LastQueryStats [TQueryStatKey{consumer->QueryId , key.ReadGroup }];
605605 if (!stat) {
606606 stat = TAggQueryStat ();
@@ -725,7 +725,7 @@ TString TRowDispatcher::GetInternalState() {
725725 }
726726 const auto & partition = consumer->Partitions [key.PartitionId ];
727727 const auto & stat = partition.Stat ;
728- str << " " << consumer->QueryId << " " << LeftPad (readActorId, 32 ) << " unread bytes "
728+ str << " " << consumer->QueryId << " " << LeftPad (readActorId, 33 ) << " unread bytes "
729729 << toHuman (stat.QueuedBytes ) << " (" << leftPad (stat.QueuedRows ) << " rows) "
730730 << " offset " << leftPad (stat.Offset ) << " init offset " << leftPad (stat.InitialOffset )
731731 << " get " << leftPad (consumer->Counters .GetNextBatch )
You can’t perform that action at this time.
0 commit comments