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;
         }