From 43acb9bb91d51fcb16175b0a0c55fe140ed3e1eb Mon Sep 17 00:00:00 2001
From: "neng.liu" <1398775315@qq.com>
Date: Wed, 13 Apr 2022 11:24:42 +0800
Subject: [PATCH] Revert "add time print in transform"

This reverts commit 401d6ec3580c7bb23c776aa864876d96016bea2f.
---
 src/Processors/ISimpleTransform.cpp | 10 +---------
 src/Processors/ISimpleTransform.h   |  1 -
 src/Processors/ISource.cpp          | 12 +-----------
 src/Processors/ISource.h            |  1 -
 4 files changed, 2 insertions(+), 22 deletions(-)

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 <Processors/ISimpleTransform.h>
-#include <Common/Stopwatch.h>
-#include <common/logger_useful.h>
+
 
 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 <Processors/ISource.h>
-#include <Common/Stopwatch.h>
-#include <common/logger_useful.h>
+
 
 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<Chunk> tryGenerate();