aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorhor911 <hor911@ydb.tech>2023-06-27 21:19:32 +0300
committerhor911 <hor911@ydb.tech>2023-06-27 21:19:32 +0300
commit514acfbfbaadd70c11764c22a12a70ae6be7810c (patch)
tree9d1334e2b254754b3e1a40ac2e6f07efe8d49b92
parent1ebff77fe0334ff7df4156cdfb330dc19d99f755 (diff)
downloadydb-514acfbfbaadd70c11764c22a12a70ae6be7810c.tar.gz
Remove Memory Usage Logging
-rw-r--r--ydb/library/yql/providers/s3/actors/yql_s3_read_actor.cpp19
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) {