Skip to content

Commit

Permalink
fix state table field data type
Browse files Browse the repository at this point in the history
Signed-off-by: Richard Chien <[email protected]>
  • Loading branch information
stdrc committed Oct 24, 2023
1 parent f32605f commit 3804bec
Showing 1 changed file with 2 additions and 5 deletions.
7 changes: 2 additions & 5 deletions src/frontend/src/optimizer/plan_node/generic/agg.rs
Original file line number Diff line number Diff line change
Expand Up @@ -516,11 +516,8 @@ impl<PlanRef: stream::StreamPlanRef> Agg<PlanRef> {
// we use materialized input state for non-retractable aggregate function.
// for backward compatibility, the state type is same as the return type.
// its values in the intermediate state table are always null.
} else {
field.data_type = sig
.state_type
.clone()
.unwrap_or(sig.ret_type.as_exact().clone());
} else if let Some(state_type) = &sig.state_type {
field.data_type = state_type.clone();
}
}
let in_dist_key = self.input.distribution().dist_column_indices().to_vec();
Expand Down

0 comments on commit 3804bec

Please sign in to comment.