From f39ad1f79a07974c0d4d1809e8adc23d57362a4c Mon Sep 17 00:00:00 2001 From: Nikolai Kochetov Date: Tue, 5 Feb 2019 16:30:59 +0300 Subject: [PATCH] Fix traverse. --- dbms/src/Processors/Executors/traverse.h | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dbms/src/Processors/Executors/traverse.h b/dbms/src/Processors/Executors/traverse.h index 356853b341f..879433de041 100644 --- a/dbms/src/Processors/Executors/traverse.h +++ b/dbms/src/Processors/Executors/traverse.h @@ -18,7 +18,7 @@ void traverse(IProcessor & processor, Visit && visit) if (status == IProcessor::Status::NeedData) for (auto & input : processor.getInputs()) - if (input.isNeeded()) + if (input.isNeeded() && !input.hasData()) traverse(input.getOutputPort().getProcessor(), std::forward(visit)); if (status == IProcessor::Status::PortFull)