diff --git a/src/Processors/ISimpleTransform.cpp b/src/Processors/ISimpleTransform.cpp index 2fc7503ad595..ac8f2f8b7ae7 100644 --- a/src/Processors/ISimpleTransform.cpp +++ b/src/Processors/ISimpleTransform.cpp @@ -1,6 +1,5 @@ #include -#include -#include + namespace DB { @@ -53,9 +52,6 @@ ISimpleTransform::Status ISimpleTransform::prepare() { if (input.isFinished()) { - LOG_DEBUG(&Poco::Logger::get(getName()), - "Processor {} used {} ms\n", - getName(), time/ 1000000UL); output.finish(); return Status::Finished; } @@ -90,11 +86,7 @@ void ISimpleTransform::work() try { - Stopwatch watch; - watch.start(); transform(input_data.chunk, output_data.chunk); - time += watch.elapsedNanoseconds(); - watch.stop(); } catch (DB::Exception &) { diff --git a/src/Processors/ISimpleTransform.h b/src/Processors/ISimpleTransform.h index bdf294c02662..ee92b574d7c0 100644 --- a/src/Processors/ISimpleTransform.h +++ b/src/Processors/ISimpleTransform.h @@ -26,7 +26,6 @@ class ISimpleTransform : public IProcessor bool has_output = false; bool no_more_data_needed = false; const bool skip_empty_chunks; - UInt64 time = 0; /// Set input port NotNeeded after chunk was pulled. /// Input port will become needed again only after data was transformed. diff --git a/src/Processors/ISource.cpp b/src/Processors/ISource.cpp index 8126630ba0fe..7ae988f7cdbe 100644 --- a/src/Processors/ISource.cpp +++ b/src/Processors/ISource.cpp @@ -1,6 +1,5 @@ #include -#include -#include + namespace DB { @@ -51,23 +50,14 @@ void ISource::work() { try { - Stopwatch watch; - watch.start(); if (auto chunk = tryGenerate()) { current_chunk.chunk = std::move(*chunk); if (current_chunk.chunk) has_input = true; - time += watch.elapsedNanoseconds(); } else - { finished = true; - LOG_DEBUG(&Poco::Logger::get(getName()), - "Processor {} used {} ms\n", - getName(), time/ 1000000UL); - } - if (isCancelled()) finished = true; diff --git a/src/Processors/ISource.h b/src/Processors/ISource.h index 7208930c179b..db91c0c5bceb 100644 --- a/src/Processors/ISource.h +++ b/src/Processors/ISource.h @@ -14,7 +14,6 @@ class ISource : public IProcessor bool finished = false; bool got_exception = false; Port::Data current_chunk; - UInt64 time = 0; virtual Chunk generate(); virtual std::optional tryGenerate();