diff --git a/src/query/src/dist_plan/commutativity.rs b/src/query/src/dist_plan/commutativity.rs index 87651c7fe0..50fe5da0e6 100644 --- a/src/query/src/dist_plan/commutativity.rs +++ b/src/query/src/dist_plan/commutativity.rs @@ -366,7 +366,8 @@ impl Categorizer { | Expr::Negative(_) | Expr::Between(_) | Expr::Exists(_) - | Expr::InList(_) => Commutativity::Commutative, + | Expr::InList(_) + | Expr::Case(_) => Commutativity::Commutative, Expr::ScalarFunction(_udf) => Commutativity::Commutative, Expr::AggregateFunction(_udaf) => Commutativity::Commutative, @@ -374,7 +375,6 @@ impl Categorizer { | Expr::SimilarTo(_) | Expr::IsUnknown(_) | Expr::IsNotUnknown(_) - | Expr::Case(_) | Expr::Cast(_) | Expr::TryCast(_) | Expr::WindowFunction(_)