File tree Expand file tree Collapse file tree 2 files changed +4
-2
lines changed
datafusion/core/tests/parquet Expand file tree Collapse file tree 2 files changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -196,6 +196,8 @@ impl ContextWithParquet {
196
196
unit : Unit ,
197
197
mut config : SessionConfig ,
198
198
) -> Self {
199
+ // Use a single partition for deterministic results no matter how many CPUs the host has
200
+ config = config. with_target_partitions ( 1 ) ;
199
201
let file = match unit {
200
202
Unit :: RowGroup ( row_per_group) => {
201
203
config = config. with_parquet_bloom_filter_pruning ( true ) ;
Original file line number Diff line number Diff line change @@ -448,7 +448,7 @@ macro_rules! int_tests {
448
448
. with_expected_errors( Some ( 0 ) )
449
449
. with_matched_by_stats( Some ( 0 ) )
450
450
. with_pruned_by_stats( Some ( 0 ) )
451
- . with_pruned_files( Some ( 3 ) )
451
+ . with_pruned_files( Some ( 1 ) )
452
452
. with_matched_by_bloom_filter( Some ( 0 ) )
453
453
. with_pruned_by_bloom_filter( Some ( 0 ) )
454
454
. with_expected_rows( 0 )
@@ -1400,7 +1400,7 @@ async fn test_row_group_with_null_values() {
1400
1400
. with_expected_errors ( Some ( 0 ) )
1401
1401
. with_matched_by_stats ( Some ( 0 ) )
1402
1402
. with_pruned_by_stats ( Some ( 0 ) )
1403
- . with_pruned_files ( Some ( 3 ) )
1403
+ . with_pruned_files ( Some ( 1 ) )
1404
1404
. with_expected_rows ( 0 )
1405
1405
. with_matched_by_bloom_filter ( Some ( 0 ) )
1406
1406
. with_pruned_by_bloom_filter ( Some ( 0 ) )
You can’t perform that action at this time.
0 commit comments