diff --git a/src/Interpreters/ClusterProxy/SelectStreamFactory.cpp b/src/Interpreters/ClusterProxy/SelectStreamFactory.cpp index 51f7e93552a..5c41b4a1fc0 100644 --- a/src/Interpreters/ClusterProxy/SelectStreamFactory.cpp +++ b/src/Interpreters/ClusterProxy/SelectStreamFactory.cpp @@ -80,7 +80,7 @@ QueryPipeline createLocalStream( pipeline.addSimpleTransform([&](const Block & source_header) { return std::make_shared( - source_header, header, ConvertingTransform::MatchColumnsMode::Name); + source_header, header, ConvertingTransform::MatchColumnsMode::Name, true); }); /** Materialization is needed, since from remote servers the constants come materialized.