return error for invalid decimal length

apache · Dec 19, 2024 · 2597c9a · 2597c9a
1 parent 55f3f64
commit 2597c9a
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/parquet/src/schema/types.rs b/parquet/src/schema/types.rs
@@ -556,7 +556,10 @@ impl<'a> PrimitiveTypeBuilder<'a> {
                 }
             }
             PhysicalType::FIXED_LEN_BYTE_ARRAY => {
-                let length = self.length.checked_mul(8).unwrap_or(i32::MAX);
+                let length = self
+                    .length
+                    .checked_mul(8)
+                    .ok_or(general_err!("Invalid length {} for Decimal", self.length))?;
                 let max_precision = (2f64.powi(length - 1) - 1f64).log10().floor() as i32;
 
                 if self.precision > max_precision {