diff options
| author | Filitov Mikhail <filitovme@gmail.com> | 2025-04-18 12:58:56 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-04-18 12:58:56 +0200 |
| commit | 62614f2f7fa863a2743bb9fabbbb6816f5b79426 (patch) | |
| tree | adfa94292ccc386c8fa69577d730be108925fb92 | |
| parent | 3892bccf1f51a1c417ce92a4883ee7b8b4434746 (diff) | |
| download | ydb-62614f2f7fa863a2743bb9fabbbb6816f5b79426.tar.gz | |
Added spilling queue counters (#17394)
| -rw-r--r-- | ydb/library/yql/dq/actors/spilling/spilling_counters.cpp | 1 | ||||
| -rw-r--r-- | ydb/library/yql/dq/actors/spilling/spilling_counters.h | 1 | ||||
| -rw-r--r-- | ydb/library/yql/dq/actors/spilling/spilling_file.cpp | 2 |
3 files changed, 4 insertions, 0 deletions
diff --git a/ydb/library/yql/dq/actors/spilling/spilling_counters.cpp b/ydb/library/yql/dq/actors/spilling/spilling_counters.cpp index 0f882d55fdb..61db94e1fdb 100644 --- a/ydb/library/yql/dq/actors/spilling/spilling_counters.cpp +++ b/ydb/library/yql/dq/actors/spilling/spilling_counters.cpp @@ -11,6 +11,7 @@ TSpillingCounters::TSpillingCounters(const TIntrusivePtr<::NMonitoring::TDynamic SpillingNoSpaceErrors = counters->GetCounter("Spilling/NoSpaceErrors", true); SpillingIoErrors = counters->GetCounter("Spilling/IoErrors", true); SpillingFileDescriptors = counters->GetCounter("Spilling/FileDescriptors", false); + SpillingIOQueueSize = counters->GetCounter("Spilling/IOQueueSize", false); } } // namespace NYql::NDq diff --git a/ydb/library/yql/dq/actors/spilling/spilling_counters.h b/ydb/library/yql/dq/actors/spilling/spilling_counters.h index 81ba98ebe7f..59b2d19f2e3 100644 --- a/ydb/library/yql/dq/actors/spilling/spilling_counters.h +++ b/ydb/library/yql/dq/actors/spilling/spilling_counters.h @@ -18,6 +18,7 @@ struct TSpillingCounters : public TThrRefBase { ::NMonitoring::TDynamicCounters::TCounterPtr SpillingNoSpaceErrors; ::NMonitoring::TDynamicCounters::TCounterPtr SpillingIoErrors; ::NMonitoring::TDynamicCounters::TCounterPtr SpillingFileDescriptors; + ::NMonitoring::TDynamicCounters::TCounterPtr SpillingIOQueueSize; }; struct TSpillingTaskCounters : public TThrRefBase { diff --git a/ydb/library/yql/dq/actors/spilling/spilling_file.cpp b/ydb/library/yql/dq/actors/spilling/spilling_file.cpp index 083b9746315..680c5560618 100644 --- a/ydb/library/yql/dq/actors/spilling/spilling_file.cpp +++ b/ydb/library/yql/dq/actors/spilling/spilling_file.cpp @@ -712,6 +712,7 @@ private: TAG(TH2) { s << "Active files"; } PRE() { s << "Used space: " << TotalSize_ << Endl; } PRE() { s << "Used file descriptors: " << Counters_->SpillingFileDescriptors->Val() << Endl; } + PRE() { s << "IO queue size: " << Counters_->SpillingIOQueueSize->Val() << Endl; } for (const auto& tx : byTx) { TAG(TH2) { s << "Transaction " << tx.first; } @@ -824,6 +825,7 @@ private: fd.HasActiveOp = true; + Counters_->SpillingIOQueueSize->Set(IoThreadPool_->Size() + 1); return IoThreadPool_->AddAndOwn(std::move(op)); } |