diff options
author | hor911 <hor911@ydb.tech> | 2023-06-27 21:19:32 +0300 |
---|---|---|
committer | hor911 <hor911@ydb.tech> | 2023-06-27 21:19:32 +0300 |
commit | 514acfbfbaadd70c11764c22a12a70ae6be7810c (patch) | |
tree | 9d1334e2b254754b3e1a40ac2e6f07efe8d49b92 | |
parent | 1ebff77fe0334ff7df4156cdfb330dc19d99f755 (diff) | |
download | ydb-514acfbfbaadd70c11764c22a12a70ae6be7810c.tar.gz |
Remove Memory Usage Logging
-rw-r--r-- | ydb/library/yql/providers/s3/actors/yql_s3_read_actor.cpp | 19 |
1 files changed, 0 insertions, 19 deletions
diff --git a/ydb/library/yql/providers/s3/actors/yql_s3_read_actor.cpp b/ydb/library/yql/providers/s3/actors/yql_s3_read_actor.cpp index 2ba03ea7d06..c3f8d44331c 100644 --- a/ydb/library/yql/providers/s3/actors/yql_s3_read_actor.cpp +++ b/ydb/library/yql/providers/s3/actors/yql_s3_read_actor.cpp @@ -128,8 +128,6 @@ using ::NYql::NS3Lister::ES3PatternType; namespace { -constexpr TDuration MEMORY_USAGE_REPORT_PERIOD = TDuration::Seconds(10); - struct TS3ReadAbort : public yexception { using yexception::yexception; }; @@ -2448,22 +2446,7 @@ private: return ReadSpec->Arrow ? NUdf::GetSizeOfArrowBatchInBytes(*block.Batch) : block.Block.bytes(); } - void ReportMemoryUsage() const { - const TInstant now = TInstant::Now(); - if (now - LastMemoryReport < MEMORY_USAGE_REPORT_PERIOD) { - return; - } - LastMemoryReport = now; - size_t blocksTotalSize = 0; - for (const auto& block : Blocks) { - blocksTotalSize += GetBlockSize(block); - } - LOG_D("TS3StreamReadActor", "Memory usage. Ready blocks: " << Blocks.size() << ". Ready blocks total size: " << blocksTotalSize); - } - i64 GetAsyncInputData(TUnboxedValueBatch& output, TMaybe<TInstant>&, bool& finished, i64 free) final { - ReportMemoryUsage(); - i64 total = 0LL; if (!Blocks.empty()) do { const i64 s = GetBlockSize(Blocks.front()); @@ -2591,7 +2574,6 @@ private: } Blocks.emplace_back(next); Send(ComputeActorId, new IDqComputeActorAsyncInput::TEvNewAsyncInputDataArrived(InputIndex)); - ReportMemoryUsage(); } void HandleNextRecordBatch(TEvPrivate::TEvNextRecordBatch::TPtr& next) { @@ -2603,7 +2585,6 @@ private: } Blocks.emplace_back(next); Send(ComputeActorId, new IDqComputeActorAsyncInput::TEvNewAsyncInputDataArrived(InputIndex)); - ReportMemoryUsage(); } void HandleFileFinished(TEvPrivate::TEvFileFinished::TPtr& ev) { |