Skip to content

Commit

Permalink
chore: clippy
Browse files Browse the repository at this point in the history
  • Loading branch information
discord9 committed Aug 2, 2024
1 parent 0edc37e commit 822eeb8
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 4 deletions.
4 changes: 1 addition & 3 deletions src/flow/src/df_optimizer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -64,9 +64,7 @@ pub async fn apply_df_optimizer(
Arc::new(TypeCoercion::new()),
]);
let plan = analyzer
.execute_and_check(plan, &cfg, |p, r| {
dbg!("rule applied", r.name(), p);
})
.execute_and_check(plan, &cfg, |_p, _r| {})
.context(DatafusionSnafu {
context: "Fail to apply analyzer",
})?;
Expand Down
2 changes: 1 addition & 1 deletion src/flow/src/transform/aggr.rs
Original file line number Diff line number Diff line change
Expand Up @@ -303,7 +303,7 @@ impl TypedPlan {
let mut output_names = Vec::new();

// first append group_expr as key, then aggr_expr as value
for (_idx, expr) in group_exprs.iter().enumerate() {
for expr in group_exprs.iter() {
output_types.push(expr.typ.clone());
let col_name = match &expr.expr {
ScalarExpr::Column(col) => input.schema.get_name(*col).clone(),
Expand Down

0 comments on commit 822eeb8

Please sign in to comment.