diff options
| author | Nikolay Shestakov <tesseract@ydb.tech> | 2024-05-03 16:44:10 +0500 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-05-03 16:44:10 +0500 |
| commit | e1880f1134c52055e98b08a265c3ffef20ca6944 (patch) | |
| tree | 67cba032dd10a787186284fd224e5c3264d87522 | |
| parent | ebb76f3b08396d74a32346ba0051dcd35ec8b9f7 (diff) | |
| download | ydb-e1880f1134c52055e98b08a265c3ffef20ca6944.tar.gz | |
fix add break (#4271)
| -rw-r--r-- | ydb/core/persqueue/read_balancer.cpp | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/ydb/core/persqueue/read_balancer.cpp b/ydb/core/persqueue/read_balancer.cpp index e05bcb4231..4c77f50d49 100644 --- a/ydb/core/persqueue/read_balancer.cpp +++ b/ydb/core/persqueue/read_balancer.cpp @@ -160,6 +160,7 @@ void TPersQueueReadBalancer::HandleWakeup(TEvents::TEvWakeup::TPtr& ev, const TA if (PartitionsScaleManager && SplitMergeEnabled(TabletConfig)) { PartitionsScaleManager->TrySendScaleRequest(ctx); } + break; } default: { GetStat(ctx); //TODO: do it only on signals from outerspace right now @@ -505,7 +506,7 @@ void TPersQueueReadBalancer::Handle(TEvPersQueue::TEvUpdateBalancerConfig::TPtr std::vector<std::pair<ui64, TTabletInfo>> newTablets; std::vector<std::pair<ui32, ui32>> newGroups; std::vector<std::pair<ui64, TTabletInfo>> reallocatedTablets; - + if (SplitMergeEnabled(TabletConfig)) { if (!PartitionsScaleManager) { PartitionsScaleManager = std::make_unique<TPartitionScaleManager>(Topic, DatabasePath, record); @@ -768,7 +769,7 @@ void TPersQueueReadBalancer::Handle(TEvPersQueue::TEvStatusResponse::TPtr& ev, c partRes.GetScaleStatus(); AggregatedStats.AggrStats(partitionId, partRes.GetPartitionSize(), partRes.GetUsedReserveSize()); - AggregatedStats.AggrStats(partRes.GetAvgWriteSpeedPerSec(), partRes.GetAvgWriteSpeedPerMin(), + AggregatedStats.AggrStats(partRes.GetAvgWriteSpeedPerSec(), partRes.GetAvgWriteSpeedPerMin(), partRes.GetAvgWriteSpeedPerHour(), partRes.GetAvgWriteSpeedPerDay()); AggregatedStats.Stats[partitionId].Counters = partRes.GetAggregatedCounters(); AggregatedStats.Stats[partitionId].HasCounters = true; |