thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-20 08:40:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update PipelineExecutor.cpp

Browse Source 
Should have used back_edges instead of direct_edges
This commit is contained in:
Mark Papadakis 2020-08-18 15:09:23 +03:00 committed by GitHub
parent fc7fb3b10a
commit 734f57462b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/Processors/Executors/PipelineExecutor.cpp
View File

@ -133,7 +133,7 @@ bool PipelineExecutor::expandPipeline(Stack & stack, UInt64 pid)
for (uint64_t node = 0; node < graph->nodes.size(); ++node) for (uint64_t node = 0; node < graph->nodes.size(); ++node)
{ {
direct_edge_sizes[node] = graph->nodes[node]->direct_edges.size(); direct_edge_sizes[node] = graph->nodes[node]->direct_edges.size();
back_edges_sizes[node] = graph->nodes[node]->direct_edges.size(); back_edges_sizes[node] = graph->nodes[node]->back_edges.size();
} }
auto updated_nodes = graph->expandPipeline(processors); auto updated_nodes = graph->expandPipeline(processors);