Merge branch 'main' of https://github.com/risingwavelabs/risingwave i…

…nto li0k/storage_recliam_table_throughput_statistic

ci/workflows/docker.yml

@@ -98,6 +98,7 @@ steps:
     retry: *auto-retry
 
   - label: "generate notification step"
+    if: build.env("ENABLE_DOCKER_SCOUT") == "true"
     depends_on:
       - "docker-scout"
     command: ci/scripts/docker-scout-notify.sh

dashboard/lib/layout.ts

@@ -516,33 +516,3 @@ export function generateFragmentEdges(
   }
   return links
 }
-
-export function generateRelationBackPressureEdges(
-  layoutMap: RelationBoxPosition[]
-): Edge[] {
-  const links = []
-  const relationMap = new Map<string, RelationBoxPosition>()
-  for (const x of layoutMap) {
-    relationMap.set(x.id, x)
-  }
-  for (const relation of layoutMap) {
-    for (const parentId of relation.parentIds) {
-      const parentRelation = relationMap.get(parentId)!
-      links.push({
-        points: [
-          {
-            x: relation.x + relation.width / 2,
-            y: relation.y + relation.height / 2,
-          },
-          {
-            x: parentRelation.x + parentRelation.width / 2,
-            y: parentRelation.y + parentRelation.height / 2,
-          },
-        ],
-        source: relation.id,
-        target: parentId,
-      })
-    }
-  }
-  return links
-}

e2e_test/over_window/generated/batch/main.slt.part

@@ -9,3 +9,4 @@ include ./expr_in_win_func/mod.slt.part
 include ./agg_in_win_func/mod.slt.part
 include ./opt_agg_then_join/mod.slt.part
 include ./with_filter/mod.slt.part
+include ./no_effect_updates/mod.slt.part

e2e_test/over_window/generated/batch/no_effect_updates/mod.slt.part

@@ -0,0 +1,94 @@
+# This file is generated by `gen.py`. Do not edit it manually!
+
+# Test handling of updates having no effect on window function outputs.
+
+statement ok
+create table t (
+      id int
+    , foo int
+    , bar int
+);
+
+statement ok
+create view v1 as
+select
+    *
+    , rank() over (partition by 1::int order by foo) as r1
+from t;
+
+statement ok
+create view v2 as
+select
+    *
+    , rank() over (partition by 1::int order by bar) as r2
+from t;
+
+statement ok
+insert into t values
+  (100001, 701, 805)
+, (100002, 700, 806)
+, (100003, 723, 807)
+, (100004, 702, 808);
+
+query iii
+select * from v1 order by r1, id;
+----
+100002 700 806 1
+100001 701 805 2
+100004 702 808 3
+100003 723 807 4
+
+query iii
+select * from v2 order by r2, id;
+----
+100001 701 805 1
+100002 700 806 2
+100003 723 807 3
+100004 702 808 4
+
+statement ok
+update t set foo = 733 where id = 100001;
+
+query iii
+select * from v1 order by r1, id;
+----
+100002 700 806 1
+100004 702 808 2
+100003 723 807 3
+100001 733 805 4
+
+query iii
+select * from v2 order by r2, id;
+----
+100001 733 805 1
+100002 700 806 2
+100003 723 807 3
+100004 702 808 4
+
+statement ok
+update t set bar = 804 where id = 100001;
+
+query iii
+select * from v1 order by r1, id;
+----
+100002 700 806 1
+100004 702 808 2
+100003 723 807 3
+100001 733 804 4
+
+query iii
+select * from v2 order by r2, id;
+----
+100001 733 804 1
+100002 700 806 2
+100003 723 807 3
+100004 702 808 4
+
+statement ok
+drop view v1;
+
+statement ok
+drop view v2;
+
+statement ok
+drop table t;

e2e_test/over_window/generated/streaming/main.slt.part

@@ -9,3 +9,4 @@ include ./expr_in_win_func/mod.slt.part
 include ./agg_in_win_func/mod.slt.part
 include ./opt_agg_then_join/mod.slt.part
 include ./with_filter/mod.slt.part
+include ./no_effect_updates/mod.slt.part