diff --git a/core/src/execution/datafusion/planner.rs b/core/src/execution/datafusion/planner.rs
index 711e40fc37..120134d5c9 100644
--- a/core/src/execution/datafusion/planner.rs
+++ b/core/src/execution/datafusion/planner.rs
@@ -28,8 +28,9 @@ use datafusion::{
         execution_props::ExecutionProps,
         expressions::{
             in_list, BinaryExpr, BitAnd, BitOr, BitXor, CaseExpr, CastExpr, Column, Count,
-            Covariance, CovariancePop, FirstValue, InListExpr, IsNotNullExpr, IsNullExpr, LastValue,
-            Literal as DataFusionLiteral, Max, Min, NegativeExpr, NotExpr, Sum, UnKnownColumn,
+            Covariance, CovariancePop, FirstValue, InListExpr, IsNotNullExpr, IsNullExpr,
+            LastValue, Literal as DataFusionLiteral, Max, Min, NegativeExpr, NotExpr, Sum,
+            UnKnownColumn,
         },
         functions::create_physical_expr,
         AggregateExpr, PhysicalExpr, PhysicalSortExpr, ScalarFunctionExpr,
@@ -1051,13 +1052,23 @@ impl PhysicalPlanner {
                 let child1 = self.create_expr(expr.child1.as_ref().unwrap(), schema.clone())?;
                 let child2 = self.create_expr(expr.child2.as_ref().unwrap(), schema.clone())?;
                 let datatype = to_arrow_datatype(expr.datatype.as_ref().unwrap());
-                Ok(Arc::new(Covariance::new(child1, child2, "covariance", datatype)))
+                Ok(Arc::new(Covariance::new(
+                    child1,
+                    child2,
+                    "covariance",
+                    datatype,
+                )))
             }
             AggExprStruct::CovPopulation(expr) => {
                 let child1 = self.create_expr(expr.child1.as_ref().unwrap(), schema.clone())?;
                 let child2 = self.create_expr(expr.child2.as_ref().unwrap(), schema.clone())?;
                 let datatype = to_arrow_datatype(expr.datatype.as_ref().unwrap());
-                Ok(Arc::new(CovariancePop::new(child1, child2, "covariance_pop", datatype)))
+                Ok(Arc::new(CovariancePop::new(
+                    child1,
+                    child2,
+                    "covariance_pop",
+                    datatype,
+                )))
             }
         }
     }