mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-09-20 08:40:50 +00:00
Fix PipelineExecutor::executeStepImpl
This commit is contained in:
parent
1f9e4996c7
commit
709f705886
@ -570,7 +570,7 @@ void PipelineExecutor::executeStepImpl(size_t thread_num, size_t num_threads, st
|
||||
{
|
||||
/// First, find any processor to execute.
|
||||
/// Just travers graph and prepare any processor.
|
||||
while (!finished && state != nullptr)
|
||||
while (!finished && state == nullptr)
|
||||
{
|
||||
{
|
||||
std::unique_lock lock(task_queue_mutex);
|
||||
|
Loading…
Reference in New Issue
Block a user