diff --git a/src/Processors/Transforms/Streaming/WatermarkTransformWithSubstream.cpp b/src/Processors/Transforms/Streaming/WatermarkTransformWithSubstream.cpp
index 46a66a9fd3..495643c130 100644
--- a/src/Processors/Transforms/Streaming/WatermarkTransformWithSubstream.cpp
+++ b/src/Processors/Transforms/Streaming/WatermarkTransformWithSubstream.cpp
@@ -193,8 +193,6 @@ void WatermarkTransformWithSubstream::work()
             output_chunks.emplace_back(std::move(process_chunk));
         }
     }
-
-    output_iter = output_chunks.begin(); /// need to output chunks
 }
 
 WatermarkStamper & WatermarkTransformWithSubstream::getOrCreateSubstreamWatermark(const SubstreamID & id)