diff --git a/tests/it/io/parquet/write.rs b/tests/it/io/parquet/write.rs index 3b7f1db120c..ef5a18888d2 100644 --- a/tests/it/io/parquet/write.rs +++ b/tests/it/io/parquet/write.rs @@ -11,6 +11,17 @@ fn round_trip( version: Version, compression: CompressionOptions, encodings: Vec, +) -> Result<()> { + round_trip_opt_stats(column, file, version, compression, encodings, true) +} + +fn round_trip_opt_stats( + column: &str, + file: &str, + version: Version, + compression: CompressionOptions, + encodings: Vec, + check_stats: bool, ) -> Result<()> { let (array, statistics) = match file { "nested" => ( @@ -56,7 +67,9 @@ fn round_trip( let (result, stats) = read_column(&mut Cursor::new(data), "a1")?; assert_eq!(array.as_ref(), result.as_ref()); - assert_eq!(statistics, stats); + if check_stats { + assert_eq!(statistics, stats); + } Ok(()) } @@ -363,12 +376,13 @@ fn list_large_binary_optional_v1() -> Result<()> { #[test] fn list_nested_inner_required_required_i64() -> Result<()> { - round_trip( + round_trip_opt_stats( "list_nested_inner_required_required_i64", "nested", Version::V1, CompressionOptions::Uncompressed, vec![Encoding::Plain], + false, ) }