diff --git a/src/Processors/QueryPlan/ReadFromStorageStep.cpp b/src/Processors/QueryPlan/ReadFromStorageStep.cpp
index bc108286ba1..14c95cbe2c2 100644
--- a/src/Processors/QueryPlan/ReadFromStorageStep.cpp
+++ b/src/Processors/QueryPlan/ReadFromStorageStep.cpp
@@ -65,13 +65,6 @@ ReadFromStorageStep::ReadFromStorageStep(
         pipes.emplace_back(std::move(pipe));
     }
 
-    if (!blocksHaveEqualStructure(pipes.front().getHeader(), input_streams.front().header))
-    {
-        for (auto & pipe : pipes)
-            pipe.addSimpleTransform(std::make_shared<ConvertingTransform>(
-                    pipe.getHeader(), input_streams.front().header, ConvertingTransform::MatchColumnsMode::Name));
-    }
-
     pipeline = std::make_unique<QueryPipeline>();
 
     /// Table lock is stored inside pipeline here.