diff --git a/src/Processors/Formats/Impl/Parquet/ParquetDataBuffer.h b/src/Processors/Formats/Impl/Parquet/ParquetDataBuffer.h index 8f0b39c917c1..9e5603eebe26 100644 --- a/src/Processors/Formats/Impl/Parquet/ParquetDataBuffer.h +++ b/src/Processors/Formats/Impl/Parquet/ParquetDataBuffer.h @@ -54,11 +54,10 @@ class ParquetDataBuffer auto necessary_bytes = count * sizeof(ParquetType); checkAvaible(necessary_bytes); - const ParquetType* src = reinterpret_cast(data); - for (std::size_t i = 0; i < count; i++) { - dst[i] = static_cast(src[i]); + auto offset = i * sizeof(ParquetType); + dst[i] = unalignedLoad(data + offset); } consume(necessary_bytes);