thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-23 08:02:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Disable logging in processors pipeline.

Browse Source
This commit is contained in:
Nikolai Kochetov 2019-12-28 21:42:07 +03:00
parent 05fe9ef179
commit 755cd1bea2
1 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
dbms/src/Processors/Executors/PipelineExecutor.cpp
View File

@ -470,12 +470,12 @@ void PipelineExecutor::executeSingleThread(size_t thread_num, size_t num_threads
#endif #endif
UInt64 total_time_ns = 0; // UInt64 total_time_ns = 0;
UInt64 execution_time_ns = 0; // UInt64 execution_time_ns = 0;
UInt64 processing_time_ns = 0; // UInt64 processing_time_ns = 0;
UInt64 wait_time_ns = 0; // UInt64 wait_time_ns = 0;
Stopwatch total_time_watch; // Stopwatch total_time_watch;
ExecutionState * state = nullptr; ExecutionState * state = nullptr;
auto prepare_processor = [&](UInt64 pid, Queue & queue) auto prepare_processor = [&](UInt64 pid, Queue & queue)
@ -713,14 +713,15 @@ void PipelineExecutor::executeSingleThread(size_t thread_num, size_t num_threads
} }
} }
total_time_ns = total_time_watch.elapsed(); // total_time_ns = total_time_watch.elapsed();
wait_time_ns = total_time_ns - execution_time_ns - processing_time_ns; // wait_time_ns = total_time_ns - execution_time_ns - processing_time_ns;
/*
LOG_TRACE(log, "Thread finished." LOG_TRACE(log, "Thread finished."
<< " Total time: " << (total_time_ns / 1e9) << " sec." << " Total time: " << (total_time_ns / 1e9) << " sec."
<< " Execution time: " << (execution_time_ns / 1e9) << " sec." << " Execution time: " << (execution_time_ns / 1e9) << " sec."
<< " Processing time: " << (processing_time_ns / 1e9) << " sec." << " Processing time: " << (processing_time_ns / 1e9) << " sec."
<< " Wait time: " << (wait_time_ns / 1e9) << "sec."); << " Wait time: " << (wait_time_ns / 1e9) << "sec.");
*/
} }
void PipelineExecutor::executeImpl(size_t num_threads) void PipelineExecutor::executeImpl(size_t num_threads)