diff --git a/datafusion/core/tests/fuzz_cases/aggregation_fuzzer/context_generator.rs b/datafusion/core/tests/fuzz_cases/aggregation_fuzzer/context_generator.rs index 6e74e8e730e5..73af6af55351 100644 --- a/datafusion/core/tests/fuzz_cases/aggregation_fuzzer/context_generator.rs +++ b/datafusion/core/tests/fuzz_cases/aggregation_fuzzer/context_generator.rs @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -use std::{cmp, sync::Arc, usize}; +use std::{cmp, sync::Arc}; use datafusion::{ datasource::MemTable, @@ -210,9 +210,9 @@ impl GeneratedSessionContextBuilder { /// The generated params for [`SessionContext`] #[derive(Debug, Clone, Copy)] pub struct SessionContextParams { - batch_size: usize, - target_partitions: usize, - skip_partial_params: SkipPartialParams, + pub batch_size: usize, + pub target_partitions: usize, + pub skip_partial_params: SkipPartialParams, } /// Partial skipping parameters diff --git a/datafusion/core/tests/fuzz_cases/aggregation_fuzzer/data_generator.rs b/datafusion/core/tests/fuzz_cases/aggregation_fuzzer/data_generator.rs index 359a06055706..9d45779295e7 100644 --- a/datafusion/core/tests/fuzz_cases/aggregation_fuzzer/data_generator.rs +++ b/datafusion/core/tests/fuzz_cases/aggregation_fuzzer/data_generator.rs @@ -108,7 +108,7 @@ impl DatasetGenerator { let sort_exprs = sort_keys .iter() .map(|key| { - let col_expr = col(&key, &schema)?; + let col_expr = col(key, schema)?; Ok(PhysicalSortExpr::new_default(col_expr)) }) .collect::>>()?; diff --git a/datafusion/core/tests/fuzz_cases/aggregation_fuzzer/fuzzer.rs b/datafusion/core/tests/fuzz_cases/aggregation_fuzzer/fuzzer.rs index e30cb41fa21b..596904f5c46a 100644 --- a/datafusion/core/tests/fuzz_cases/aggregation_fuzzer/fuzzer.rs +++ b/datafusion/core/tests/fuzz_cases/aggregation_fuzzer/fuzzer.rs @@ -253,8 +253,8 @@ impl AggregationFuzzTestTask { e.row_idx, e.lhs_row, e.rhs_row, - pretty_format_batches(&task_result).unwrap(), - pretty_format_batches(&expected_result).unwrap(), + pretty_format_batches(task_result).unwrap(), + pretty_format_batches(expected_result).unwrap(), ); // Then we just panic diff --git a/test-utils/Cargo.toml b/test-utils/Cargo.toml index 01f914b97895..414fa5569cfe 100644 --- a/test-utils/Cargo.toml +++ b/test-utils/Cargo.toml @@ -29,5 +29,5 @@ workspace = true arrow = { workspace = true } datafusion-common = { workspace = true, default-features = true } env_logger = { workspace = true } -rand = { workspace = true } paste = "1.0.15" +rand = { workspace = true }