fix: test of tumble

GreptimeTeam · May 23, 2024 · cdc6550 · cdc6550
1 parent 969ebd6
commit cdc6550
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/src/flow/src/transform/aggr.rs b/src/flow/src/transform/aggr.rs
@@ -537,19 +537,19 @@ mod test {
                             ColumnType::new(CDT::uint32_datatype(), false),   // number(pk)
                             // values
                             ColumnType::new(CDT::uint64_datatype(), true), // avg.sum(number)
-                            ColumnType::new(CDT::uint64_datatype(), true), // avg.count(number)
+                            ColumnType::new(CDT::int64_datatype(), true),  // avg.count(number)
                         ])
                         .with_key(vec![1, 2])
                         .with_time_index(Some(0)),
                     ),
                 ),
                 mfp: MapFilterProject::new(5)
                     .map(vec![
-                        avg_expr,              // avg(number)
+                        avg_expr,
                         ScalarExpr::Column(2), // number(pk)
-                        ScalarExpr::Column(5),
-                        ScalarExpr::Column(0),
-                        ScalarExpr::Column(1),
+                        ScalarExpr::Column(5), // avg.sum(number)
+                        ScalarExpr::Column(0), // window start
+                        ScalarExpr::Column(1), // window end
                     ])
                     .unwrap()
                     .project(vec![6, 7, 8, 9])