From a7dc15f25af1ad13b9faa660c4ac7347ac8222ed Mon Sep 17 00:00:00 2001
From: coastalwhite <me@gburghoorn.com>
Date: Tue, 30 Jul 2024 12:55:22 +0200
Subject: [PATCH] fix: Parquet Decimal type reading

---
 crates/polars-parquet/src/arrow/read/deserialize/nested.rs | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/crates/polars-parquet/src/arrow/read/deserialize/nested.rs b/crates/polars-parquet/src/arrow/read/deserialize/nested.rs
index 9a300cc7231d..1f7f7dbaa2ac 100644
--- a/crates/polars-parquet/src/arrow/read/deserialize/nested.rs
+++ b/crates/polars-parquet/src/arrow/read/deserialize/nested.rs
@@ -264,7 +264,7 @@ pub fn columns_to_iter_recursive(
                     PhysicalType::FixedLenByteArray(size) => {
                         let (mut nested, array) = PageNestedDecoder::new(
                             columns.pop().unwrap(),
-                            field.data_type().clone(),
+                            ArrowDataType::FixedSizeBinary(size),
                             fixed_size_binary::BinaryDecoder { size },
                             init,
                         )?
@@ -320,7 +320,7 @@ pub fn columns_to_iter_recursive(
                     PhysicalType::FixedLenByteArray(size) if size <= 16 => {
                         let (mut nested, array) = PageNestedDecoder::new(
                             columns.pop().unwrap(),
-                            field.data_type().clone(),
+                            ArrowDataType::FixedSizeBinary(size),
                             fixed_size_binary::BinaryDecoder { size },
                             init,
                         )?
@@ -349,7 +349,7 @@ pub fn columns_to_iter_recursive(
                     PhysicalType::FixedLenByteArray(size) if size <= 32 => {
                         let (mut nested, array) = PageNestedDecoder::new(
                             columns.pop().unwrap(),
-                            field.data_type().clone(),
+                            ArrowDataType::FixedSizeBinary(size),
                             fixed_size_binary::BinaryDecoder { size },
                             init,
                         )?