From 734f57462b06c84ce843d43fcb32eca8bf1aa83a Mon Sep 17 00:00:00 2001 From: Mark Papadakis Date: Tue, 18 Aug 2020 15:09:23 +0300 Subject: [PATCH] Update PipelineExecutor.cpp Should have used back_edges instead of direct_edges --- src/Processors/Executors/PipelineExecutor.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/Processors/Executors/PipelineExecutor.cpp b/src/Processors/Executors/PipelineExecutor.cpp index ffb19f08c5d..cacd8fced8d 100644 --- a/src/Processors/Executors/PipelineExecutor.cpp +++ b/src/Processors/Executors/PipelineExecutor.cpp @@ -133,7 +133,7 @@ bool PipelineExecutor::expandPipeline(Stack & stack, UInt64 pid) for (uint64_t node = 0; node < graph->nodes.size(); ++node) { 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);