Skip to content

Commit 6a3d4f8

Browse files
committed
fix
1 parent a93e81e commit 6a3d4f8

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

datafusion/physical-optimizer/src/enforce_distribution.rs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -981,6 +981,7 @@ fn add_merge_on_top(
981981
/// ```text
982982
/// "DataSourceExec: file_groups={2 groups: \[\[x], \[y]]}, projection=\[a, b, c, d, e], output_ordering=\[a@0 ASC], file_type=parquet",
983983
/// ```
984+
#[allow(clippy::type_complexity)]
984985
fn remove_dist_changing_operators(
985986
mut distribution_context: DistributionContext,
986987
) -> Result<(
@@ -1222,7 +1223,7 @@ pub fn ensure_distribution(
12221223
children,
12231224
},
12241225
mut fetch,
1225-
spm,
1226+
_spm,
12261227
) = remove_dist_changing_operators(dist_context)?;
12271228

12281229
if let Some(exec) = plan.as_any().downcast_ref::<WindowAggExec>() {

0 commit comments

Comments
 (0)