From 61594edceef5690711bb972ada8dcf79e9d7113e Mon Sep 17 00:00:00 2001 From: Nikolai Kochetov Date: Fri, 17 Jan 2020 20:04:37 +0300 Subject: [PATCH] Fix StrictResize processor. --- dbms/src/Processors/ResizeProcessor.cpp | 2 ++ 1 file changed, 2 insertions(+) diff --git a/dbms/src/Processors/ResizeProcessor.cpp b/dbms/src/Processors/ResizeProcessor.cpp index 960c08505e4..6de920126d4 100644 --- a/dbms/src/Processors/ResizeProcessor.cpp +++ b/dbms/src/Processors/ResizeProcessor.cpp @@ -316,6 +316,8 @@ IProcessor::Status StrictResizeProcessor::prepare(const PortNumbers & updated_in { input.status = InputStatus::Finished; ++num_finished_inputs; + + waiting_outputs.push(input.waiting_output); } continue; }