diff options
| author | vvvv <[email protected]> | 2025-03-18 12:30:14 +0300 |
|---|---|---|
| committer | vvvv <[email protected]> | 2025-03-18 12:50:39 +0300 |
| commit | 269125dc862303a37741dfda6fcb2199aa7d329a (patch) | |
| tree | ebb781c65b15b0911e631f85043bf65b50edb0f8 /yql/essentials/minikql/computation/mkql_computation_node.cpp | |
| parent | 39355151af244681ffa988fda4b79f3f01da8797 (diff) | |
YQL-19712 RuntimeLogLevel setting, mrjob logger
init
commit_hash:6178c9e20a737d499b13f1b38fdfb621f2d8db2f
Diffstat (limited to 'yql/essentials/minikql/computation/mkql_computation_node.cpp')
| -rw-r--r-- | yql/essentials/minikql/computation/mkql_computation_node.cpp | 19 |
1 files changed, 13 insertions, 6 deletions
diff --git a/yql/essentials/minikql/computation/mkql_computation_node.cpp b/yql/essentials/minikql/computation/mkql_computation_node.cpp index 274618248d7..7fa810fb8cd 100644 --- a/yql/essentials/minikql/computation/mkql_computation_node.cpp +++ b/yql/essentials/minikql/computation/mkql_computation_node.cpp @@ -68,20 +68,27 @@ TComputationContext::TComputationContext(const THolderFactory& holderFactory, WideFields[fieldIdx + i] = &MutableValues[mutableIdx + i]; } } + + RssLogger = MakeLogger(); + RssLoggerComponent = RssLogger->RegisterComponent("TrackRss"); } TComputationContext::~TComputationContext() { #ifndef NDEBUG if (RssCounter) { - Cerr << "UsageOnFinish: graph=" << HolderFactory.GetPagePool().GetUsed() + RssLogger->Log(RssLoggerComponent, NUdf::ELogLevel::Info, TStringBuilder() + << "UsageOnFinish: graph=" << HolderFactory.GetPagePool().GetUsed() << ", rss=" << TRusage::Get().MaxRss << ", peakAlloc=" << HolderFactory.GetPagePool().GetPeakAllocated() - << ", adjustor=" << UsageAdjustor - << Endl; + << ", adjustor=" << UsageAdjustor); } #endif } +NUdf::TLoggerPtr TComputationContext::MakeLogger() const { + return LogProvider ? LogProvider->MakeLogger() : NUdf::MakeNullLogger(); +} + void TComputationContext::UpdateUsageAdjustor(ui64 memLimit) { const auto rss = TRusage::Get().MaxRss; if (!InitRss) { @@ -106,11 +113,11 @@ void TComputationContext::UpdateUsageAdjustor(ui64 memLimit) { #ifndef NDEBUG if (printUsage) { - Cerr << "Usage: graph=" << HolderFactory.GetPagePool().GetUsed() + RssLogger->Log(RssLoggerComponent, NUdf::ELogLevel::Info, TStringBuilder() + << "Usage: graph=" << HolderFactory.GetPagePool().GetUsed() << ", rss=" << rss << ", peakAlloc=" << HolderFactory.GetPagePool().GetPeakAllocated() - << ", adjustor=" << UsageAdjustor - << Endl; + << ", adjustor=" << UsageAdjustor); LastPrintUsage = TInstant::Now(); } #endif |