diff --git a/dbms/src/DataStreams/ConvertingBlockInputStream.cpp b/dbms/src/DataStreams/ConvertingBlockInputStream.cpp index d46c3693f6e..ae4d2e592e0 100644 --- a/dbms/src/DataStreams/ConvertingBlockInputStream.cpp +++ b/dbms/src/DataStreams/ConvertingBlockInputStream.cpp @@ -103,7 +103,7 @@ Block ConvertingBlockInputStream::readImpl() ColumnPtr converted = castColumnWithDiagnostic(src_elem, res_elem, context); - if (isColumnConst(*src_elem.column) && !isColumnConst(*res_elem.column)) + if (!isColumnConst(*res_elem.column)) converted = recursiveMaterializeConstants(converted); res_elem.column = std::move(converted);