diff --git a/dbms/src/Processors/QueryPipeline.cpp b/dbms/src/Processors/QueryPipeline.cpp
index 0a9bf96a0ad..59c76833582 100644
--- a/dbms/src/Processors/QueryPipeline.cpp
+++ b/dbms/src/Processors/QueryPipeline.cpp
@@ -120,7 +120,7 @@ void QueryPipeline::addSimpleTransformImpl(const TProcessorGetter & getter)
         if (!stream)
             return;
 
-        auto transform = callProcessorGetter(current_header, getter, stream_type);
+        auto transform = callProcessorGetter(stream->getHeader(), getter, stream_type);
 
         if (transform)
         {