diff --git a/src/query/src/dist_plan/commutativity.rs b/src/query/src/dist_plan/commutativity.rs index f8b3b18f1c..91aa909622 100644 --- a/src/query/src/dist_plan/commutativity.rs +++ b/src/query/src/dist_plan/commutativity.rs @@ -144,7 +144,7 @@ impl Categorizer { } } // all group by expressions are partition columns can push down, unless - // another push down(including `Limit` or `Sort`) is already in progress(which will then prvent next cond commutative node from being push down). + // another push down(including `Limit` or `Sort`) is already in progress(which will then prevent next cond commutative node from being push down). // TODO(discord9): This is a temporary solution(that works), a better description of // commutativity is needed under this situation. Commutativity::ConditionalCommutative(None) diff --git a/src/query/src/query_engine/state.rs b/src/query/src/query_engine/state.rs index d232c0367d..4a2e6dc67d 100644 --- a/src/query/src/query_engine/state.rs +++ b/src/query/src/query_engine/state.rs @@ -234,7 +234,7 @@ impl QueryEngineState { rules.retain(|rule| rule.name() != name); } - /// Optimize the logical plan by the extension anayzer rules. + /// Optimize the logical plan by the extension analyzer rules. pub fn optimize_by_extension_rules( &self, plan: DfLogicalPlan,