Skip to content

Commit d51ba0b

Browse files
committed
fix ci
1 parent dea2991 commit d51ba0b

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

datafusion/core/tests/fuzz_cases/sort_preserving_repartition_fuzz.rs

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -45,13 +45,11 @@ mod sp_repartition_fuzz_tests {
4545
use test_utils::add_empty_batches;
4646

4747
use datafusion_physical_expr_common::sort_expr::LexOrdering;
48+
use datafusion_physical_plan::source::DataSourceExec;
4849
use datafusion_physical_plan::{
4950
memory::MemorySourceConfig,
5051
repartition::on_demand_repartition::OnDemandRepartitionExec,
5152
};
52-
use datafusion_physical_plan::{
53-
repartition::on_demand_repartition, source::DataSourceExec,
54-
};
5553
use itertools::izip;
5654
use rand::{rngs::StdRng, seq::SliceRandom, Rng, SeedableRng};
5755

@@ -369,7 +367,10 @@ mod sp_repartition_fuzz_tests {
369367
let schema = input1[0].schema();
370368
let mut session_config = SessionConfig::new().with_batch_size(50);
371369
if use_on_demand_repartition {
372-
session_config.options_mut().optimizer.prefer_round_robin_repartition = false;
370+
session_config
371+
.options_mut()
372+
.optimizer
373+
.prefer_round_robin_repartition = false;
373374
}
374375
let ctx = SessionContext::new_with_config(session_config);
375376
let mut sort_keys = LexOrdering::default();

0 commit comments

Comments
 (0)