diff --git a/ydb/core/fq/libs/row_dispatcher/topic_session.cpp b/ydb/core/fq/libs/row_dispatcher/topic_session.cpp index 148dfee173f9..333deacc279f 100644 --- a/ydb/core/fq/libs/row_dispatcher/topic_session.cpp +++ b/ydb/core/fq/libs/row_dispatcher/topic_session.cpp @@ -34,7 +34,7 @@ struct TTopicSessionMetrics { ReconnectRate = PartitionGroup->GetCounter("ReconnectRate", true); RestartSessionByOffsets = PartitionGroup->GetCounter("RestartSessionByOffsets", true); SessionDataRate = PartitionGroup->GetCounter("SessionDataRate", true); - WaitEventTimeMs = PartitionGroup->GetHistogram("WaitEventTimeMs", NMonitoring::ExponentialHistogram(13, 2, 1)); // ~ 1ms -> ~ 8s + WaitEventTimeMs = PartitionGroup->GetHistogram("WaitEventTimeMs", NMonitoring::ExplicitHistogram({5, 20, 100, 500, 2000})); UnreadBytes = PartitionGroup->GetCounter("UnreadBytes"); } diff --git a/ydb/library/yql/providers/pq/async_io/dq_pq_read_actor.cpp b/ydb/library/yql/providers/pq/async_io/dq_pq_read_actor.cpp index df2097040e5f..307b767ad593 100644 --- a/ydb/library/yql/providers/pq/async_io/dq_pq_read_actor.cpp +++ b/ydb/library/yql/providers/pq/async_io/dq_pq_read_actor.cpp @@ -102,7 +102,7 @@ class TDqPqReadActor : public NActors::TActor, public NYql::NDq: AsyncInputDataRate = task->GetCounter("AsyncInputDataRate", true); ReconnectRate = task->GetCounter("ReconnectRate", true); DataRate = task->GetCounter("DataRate", true); - WaitEventTimeMs = source->GetHistogram("WaitEventTimeMs", NMonitoring::ExponentialHistogram(13, 2, 1)); // ~ 1ms -> ~ 8s + WaitEventTimeMs = source->GetHistogram("WaitEventTimeMs", NMonitoring::ExplicitHistogram({5, 20, 100, 500, 2000})); } ~TMetrics() {