init commit

ci/workflows/main-cron.yml

@@ -156,7 +156,7 @@ steps:
     retry: *auto-retry
 
   - label: "recovery test (deterministic simulation)"
-    command: "KILL_RATE=1.0 timeout 14m ci/scripts/deterministic-recovery-test.sh"
+    command: "KILL_RATE=1.0 ci/scripts/deterministic-recovery-test.sh"
     depends_on: "build-simulation"
     plugins:
       - gencer/cache#v2.4.10: *cargo-cache
@@ -165,7 +165,7 @@ steps:
           config: ci/docker-compose.yml
           mount-buildkite-agent: true
       - ./ci/plugins/upload-failure-logs
-    timeout_in_minutes: 15
+    timeout_in_minutes: 30
     retry: *auto-retry
 
   - label: "misc check"

e2e_test/streaming/nexmark/create_views.slt.part

@@ -16,3 +16,8 @@ include ./views/q18.slt.part
 include ./views/q20.slt.part
 include ./views/q21.slt.part
 include ./views/q22.slt.part
+include ./views/q101.slt.part
+include ./views/q102.slt.part
+include ./views/q103.slt.part
+include ./views/q104.slt.part
+include ./views/q105.slt.part

e2e_test/streaming/nexmark/drop_views.slt.part

@@ -51,3 +51,18 @@ drop materialized view nexmark_q21;
 
 statement ok
 drop materialized view nexmark_q22;
+
+statement ok
+drop materialized view nexmark_q101;
+
+statement ok
+drop materialized view nexmark_q102;
+
+statement ok
+drop materialized view nexmark_q103;
+
+statement ok
+drop materialized view nexmark_q104;
+
+statement ok
+drop materialized view nexmark_q105;

e2e_test/streaming/nexmark/q101.slt.part

@@ -0,0 +1,43 @@
+query ITI rowsort
+select * from nexmark_q101;
+----
+1000 mksxmeugsicmeb 73134520
+1001 k y 96533552
+1002 krxahy nnop 190
+1003 rkfwyjc 89027544
+1004 dwa 783536
+1005 noz wkctocmnkoysry NULL
+1006 fvfvyprmeqcfmsokjaj 21659600
+1007 qvjhifyhqrgouso 242
+1008 mdtztirzcsh 28953332
+1009 dfa 209960
+1010 mscya c 2092
+1011 fpwuutxfpbotietnq 12201
+1012 vxhbxffngwfonbmtp 71083760
+1013 pkfbpco NULL
+1014 yzylvbgu NULL
+1015 jal tutpl NULL
+1016 tpah NULL
+1017 orybsrq NULL
+1018 ummtst pqmnmvzcprc NULL
+1019 ole smes NULL
+1020 mlloaz NULL
+1021 ryoodotkkfv NULL
+1022 uayuy NULL
+1023 cvmrs gkxasikxi kc NULL
+1024 ifmhi ypgzxk NULL
+1025 md sfewmlfan NULL
+1026 xasxguxop NULL
+1027 nhhbp sdiyrb NULL
+1028 svfyy NULL
+1029 tevdjmgrdjokfsiyt NULL
+1030 afqptpxmwtiu NULL
+1031 gmkdrtwa cqnsv s NULL
+1032 ylrniqcte u NULL
+1033 otevr b xt eiyqwfb NULL
+1034 urisndj chkpbhr NULL
+1035 smavhcfbkd NULL
+1036 hpmxsabn NULL
+1037 glkhbaqx woh jggtio NULL
+1038 wldllwpuj NULL
+1039 sibsb wgqc NULL

e2e_test/streaming/nexmark/q102.slt.part

@@ -0,0 +1,6 @@
+query ITI rowsort
+select * from nexmark_q102;
+----
+1000 mksxmeugsicmeb 24
+1001 k  y 4
+1012 vxhbxffngwfonbmtp 5

e2e_test/streaming/nexmark/q103.slt.part

@@ -0,0 +1,4 @@
+query IT rowsort
+select * from nexmark_q103;
+----
+1000 mksxmeugsicmeb

e2e_test/streaming/nexmark/q104.slt.part

@@ -0,0 +1,32 @@
+query IT rowsort
+select * from nexmark_q104;
+----
+1000 mksxmeugsicmeb
+1005 noz wkctocmnkoysry
+1013 pkfbpco
+1014 yzylvbgu
+1015 jal tutpl
+1016 tpah
+1017 orybsrq
+1018 ummtst pqmnmvzcprc
+1019 ole smes
+1020 mlloaz
+1021 ryoodotkkfv
+1022 uayuy
+1023 cvmrs gkxasikxi kc
+1024 ifmhi ypgzxk
+1025 md sfewmlfan
+1026 xasxguxop
+1027 nhhbp sdiyrb
+1028 svfyy
+1029 tevdjmgrdjokfsiyt
+1030 afqptpxmwtiu
+1031 gmkdrtwa cqnsv s
+1032 ylrniqcte u
+1033 otevr b xt eiyqwfb
+1034 urisndj chkpbhr
+1035 smavhcfbkd
+1036 hpmxsabn
+1037 glkhbaqx woh jggtio
+1038 wldllwpuj
+1039 sibsb wgqc

e2e_test/streaming/nexmark/q105.slt.part

@@ -0,0 +1,15 @@
+query ITI rowsort
+select * from nexmark_q105;
+----
+1000 mksxmeugsicmeb             24
+1001 k  y                        4
+1002 krxahy nnop                 1
+1003 rkfwyjc                     2
+1004 dwa                         3
+1006 fvfvyprmeqcfmsokjaj         3
+1007 qvjhifyhqrgouso             1
+1008 mdtztirzcsh                 1
+1009 dfa                         2
+1010 mscya c                     2
+1011 fpwuutxfpbotietnq           2
+1012 vxhbxffngwfonbmtp           5

e2e_test/streaming/nexmark/test_mv_result.slt.part

@@ -0,0 +1,24 @@
+# Test each query
+include ./q0.slt.part
+include ./q1.slt.part
+include ./q2.slt.part
+include ./q3.slt.part
+include ./q4.slt.part
+include ./q5.slt.part
+include ./q7.slt.part
+include ./q8.slt.part
+include ./q9.slt.part
+include ./q10.slt.part
+include ./q14.slt.part
+include ./q15.slt.part
+include ./q16.slt.part
+include ./q17.slt.part
+include ./q18.slt.part
+include ./q20.slt.part
+include ./q21.slt.part
+include ./q22.slt.part
+include ./q101.slt.part
+include ./q102.slt.part
+include ./q103.slt.part
+include ./q104.slt.part
+include ./q105.slt.part

e2e_test/streaming/nexmark/views/q1.slt.part

@@ -1,9 +1,3 @@
-# -------------------------------------------------------------------------------------------------
-# Query1: Currency conversion
-# -------------------------------------------------------------------------------------------------
-# Convert each bid value from dollars to euros. Illustrates a simple transformation.
-# -------------------------------------------------------------------------------------------------
-
 statement ok
 CREATE MATERIALIZED VIEW nexmark_q1
 AS

e2e_test/streaming/nexmark/views/q101.slt.part

@@ -0,0 +1,15 @@
+statement ok
+CREATE MATERIALIZED VIEW nexmark_q101
+AS
+SELECT
+    a.id AS auction_id,
+    a.item_name AS auction_item_name,
+    b.max_price AS current_highest_bid
+FROM auction a
+LEFT OUTER JOIN (
+    SELECT
+        b1.auction,
+        MAX(b1.price) max_price
+    FROM bid b1
+    GROUP BY b1.auction
+) b ON a.id = b.auction;

e2e_test/streaming/nexmark/views/q102.slt.part

@@ -0,0 +1,13 @@
+statement ok
+CREATE MATERIALIZED VIEW nexmark_q102
+AS
+SELECT
+    a.id AS auction_id,
+    a.item_name AS auction_item_name,
+    COUNT(b.auction) AS bid_count
+FROM auction a
+JOIN bid b ON a.id = b.auction
+GROUP BY a.id, a.item_name
+HAVING COUNT(b.auction) >= (
+    SELECT COUNT(*) / COUNT(DISTINCT auction) FROM bid
+);