fix: fix the changes I made by mistake when merging #8146

risingwavelabs · Feb 24, 2023 · 79767e2 · 79767e2
1 parent 0dc8602
commit 79767e2
Show file tree

Hide file tree

Showing 5 changed files with 9 additions and 9 deletions.
diff --git a/src/frontend/planner_test/tests/testdata/nexmark_source.yaml b/src/frontend/planner_test/tests/testdata/nexmark_source.yaml
@@ -355,7 +355,7 @@
           |       └─StreamHopWindow { time_col: date_time, slide: 00:00:02, size: 00:00:10, output: [auction, window_start, _row_id] }
           |         └─StreamFilter { predicate: IsNotNull(date_time) }
           |           └─StreamProject { exprs: [auction, date_time, _row_id] }
-          |             └─StreamShare { id = 1313 }
+          |             └─StreamShare { id = 919 }
           |               └─StreamProject { exprs: [auction, date_time, _row_id] }
           |                 └─StreamFilter { predicate: IsNotNull(date_time) }
           |                   └─StreamRowIdGen { row_id_index: 7 }
@@ -369,7 +369,7 @@
                       └─StreamHopWindow { time_col: date_time, slide: 00:00:02, size: 00:00:10, output: [auction, window_start, _row_id] }
                         └─StreamFilter { predicate: IsNotNull(date_time) }
                           └─StreamProject { exprs: [auction, date_time, _row_id] }
-                            └─StreamShare { id = 1313 }
+                            └─StreamShare { id = 919 }
                               └─StreamProject { exprs: [auction, date_time, _row_id] }
                                 └─StreamFilter { predicate: IsNotNull(date_time) }
                                   └─StreamRowIdGen { row_id_index: 7 }

diff --git a/src/frontend/planner_test/tests/testdata/predicate_pushdown.yaml b/src/frontend/planner_test/tests/testdata/predicate_pushdown.yaml
@@ -54,7 +54,7 @@
   logical_plan: |
     LogicalProject { exprs: [t.v1, t.v2, t.v3, t.v4, t.ts, window_start, window_end] }
     └─LogicalFilter { predicate: (t.v1 = 10:Int32) AND (t.v2 = 20:Int32) AND (t.v3 = 30:Int32) AND (t.ts >= '1997-07-01':Date) AND (window_start >= '1997-07-02':Date) AND (window_end >= '1997-07-03':Date) AND (window_start >= (t.ts + '1 day':Interval)) AND (window_end > (t.ts + '4 days':Interval)) }
-      └─LogicalShare { id = 11 }
+      └─LogicalShare { id = 5 }
         └─LogicalProject { exprs: [t.v1, t.v2, t.v3, t.v4, t.ts, window_start, window_end] }
           └─LogicalHopWindow { time_col: t.ts, slide: 1 day, size: 3 days, output: all }
             └─LogicalFilter { predicate: IsNotNull(t.ts) }
@@ -71,7 +71,7 @@
   logical_plan: |
     LogicalProject { exprs: [window_end, t.v4, t.v2] }
     └─LogicalFilter { predicate: (window_end > '2022-01-01':Date) AND (t.v4 = 10:Int32) AND (t.v2 > 20:Int32) }
-      └─LogicalShare { id = 11 }
+      └─LogicalShare { id = 5 }
         └─LogicalProject { exprs: [window_end, t.v4, t.v2] }
           └─LogicalHopWindow { time_col: t.ts, slide: 1 day, size: 3 days, output: all }
             └─LogicalFilter { predicate: IsNotNull(t.ts) }

diff --git a/src/frontend/planner_test/tests/testdata/share.yaml b/src/frontend/planner_test/tests/testdata/share.yaml
@@ -130,7 +130,7 @@
           |       └─StreamHopWindow { time_col: date_time, slide: 00:00:02, size: 00:00:10, output: [auction, window_start, _row_id] }
           |         └─StreamFilter { predicate: IsNotNull(date_time) }
           |           └─StreamProject { exprs: [auction, date_time, _row_id] }
-          |             └─StreamShare { id = 1313 }
+          |             └─StreamShare { id = 919 }
           |               └─StreamProject { exprs: [auction, date_time, _row_id] }
           |                 └─StreamFilter { predicate: IsNotNull(date_time) }
           |                   └─StreamRowIdGen { row_id_index: 7 }
@@ -144,7 +144,7 @@
                       └─StreamHopWindow { time_col: date_time, slide: 00:00:02, size: 00:00:10, output: [auction, window_start, _row_id] }
                         └─StreamFilter { predicate: IsNotNull(date_time) }
                           └─StreamProject { exprs: [auction, date_time, _row_id] }
-                            └─StreamShare { id = 1313 }
+                            └─StreamShare { id = 919 }
                               └─StreamProject { exprs: [auction, date_time, _row_id] }
                                 └─StreamFilter { predicate: IsNotNull(date_time) }
                                   └─StreamRowIdGen { row_id_index: 7 }

diff --git a/src/frontend/planner_test/tests/testdata/subquery.yaml b/src/frontend/planner_test/tests/testdata/subquery.yaml
@@ -218,14 +218,14 @@
             └─LogicalValues { rows: [[]], schema: Schema { fields: [] } }
   optimized_logical_plan: |
     LogicalJoin { type: LeftSemi, on: IsNotDistinctFrom(auction.date_time, auction.date_time), output: all }
-    ├─LogicalShare { id = 248 }
+    ├─LogicalShare { id = 125 }
     | └─LogicalHopWindow { time_col: auction.date_time, slide: 00:00:01, size: 01:00:00, output: all }
     |   └─LogicalScan { table: auction, columns: [auction.date_time], predicate: IsNotNull(auction.date_time) }
     └─LogicalProject { exprs: [auction.date_time] }
       └─LogicalAgg { group_key: [auction.date_time, auction.date_time], aggs: [] }
         └─LogicalJoin { type: Inner, on: true, output: [auction.date_time, auction.date_time] }
           ├─LogicalAgg { group_key: [auction.date_time], aggs: [] }
-          | └─LogicalShare { id = 248 }
+          | └─LogicalShare { id = 125 }
           |   └─LogicalHopWindow { time_col: auction.date_time, slide: 00:00:01, size: 01:00:00, output: all }
           |     └─LogicalScan { table: auction, columns: [auction.date_time], predicate: IsNotNull(auction.date_time) }
           └─LogicalValues { rows: [[]], schema: Schema { fields: [] } }

diff --git a/src/frontend/planner_test/tests/testdata/time_window.yaml b/src/frontend/planner_test/tests/testdata/time_window.yaml
@@ -186,7 +186,7 @@
     LogicalProject { exprs: [t1.id, t1.v1, t1.created_at, window_start, window_end] }
     └─LogicalHopWindow { time_col: t1.created_at, slide: 1 day, size: 3 days, output: all }
       └─LogicalFilter { predicate: IsNotNull(t1.created_at) }
-        └─LogicalShare { id = 10 }
+        └─LogicalShare { id = 4 }
           └─LogicalProject { exprs: [t1.id, t1.v1, t1.created_at] }
             └─LogicalFilter { predicate: (t1.v1 >= 10:Int32) }
               └─LogicalScan { table: t1, columns: [t1.id, t1.v1, t1.created_at, t1._row_id] }