diff --git a/cpp/submodules/parquet-testing b/cpp/submodules/parquet-testing index 2fc3ade4ccbf..46c9e977f58f 160000 --- a/cpp/submodules/parquet-testing +++ b/cpp/submodules/parquet-testing @@ -1 +1 @@ -Subproject commit 2fc3ade4ccbf17271194df0b1549bc6733204314 +Subproject commit 46c9e977f58f6c5ef1b81f782f3746b3656e5a8c diff --git a/rust/datafusion/tests/sql.rs b/rust/datafusion/tests/sql.rs index ebc936b796bd..9c0adc98d810 100644 --- a/rust/datafusion/tests/sql.rs +++ b/rust/datafusion/tests/sql.rs @@ -94,6 +94,21 @@ fn parquet_query() { assert_eq!(expected, actual); } +#[test] +fn parquet_single_nan_schema() { + let mut ctx = ExecutionContext::new(); + let testdata = env::var("PARQUET_TEST_DATA").expect("PARQUET_TEST_DATA not defined"); + ctx.register_parquet("single_nan", &format!("{}/single_nan.parquet", testdata)) + .unwrap(); + let sql = "SELECT mycol FROM single_nan"; + let relation = ctx.sql(&sql, 1024 * 1024).unwrap(); + let mut results = relation.borrow_mut(); + while let Some(batch) = results.next().unwrap() { + assert_eq!(1, batch.num_rows()); + assert_eq!(1, batch.num_columns()); + } +} + #[test] fn csv_count_star() { let mut ctx = ExecutionContext::new();