diff --git a/tests/cases/standalone/common/flow/basic.result b/tests/cases/standalone/common/flow/basic.result index 9b8273655e..77f3b8683b 100644 --- a/tests/cases/standalone/common/flow/basic.result +++ b/tests/cases/standalone/common/flow/basic.result @@ -14,6 +14,7 @@ SELECT sum(number) FROM numbers_input GROUP BY tumble(ts, '1 second', '2021-07-0 Affected Rows: 0 +-- SQLNESS SLEEP 500ms INSERT INTO numbers_input VALUES (20, "2021-07-01 00:00:00.200"), @@ -30,6 +31,7 @@ SELECT col_0, window_start, window_end FROM out_num_cnt; | 42 | 2021-07-01T00:00:00 | 2021-07-01T00:00:01 | +-------+---------------------+---------------------+ +-- SQLNESS SLEEP 500ms INSERT INTO numbers_input VALUES (23,"2021-07-01 00:00:01.000"), @@ -37,7 +39,7 @@ VALUES Affected Rows: 2 --- SQLNESS SLEEP 2s +-- SQLNESS SLEEP 3s SELECT col_0, window_start, window_end FROM out_num_cnt; +-------+---------------------+---------------------+ diff --git a/tests/cases/standalone/common/flow/basic.sql b/tests/cases/standalone/common/flow/basic.sql index d7beba69ce..ddef6cff9f 100644 --- a/tests/cases/standalone/common/flow/basic.sql +++ b/tests/cases/standalone/common/flow/basic.sql @@ -10,6 +10,7 @@ SINK TO out_num_cnt AS SELECT sum(number) FROM numbers_input GROUP BY tumble(ts, '1 second', '2021-07-01 00:00:00'); +-- SQLNESS SLEEP 500ms INSERT INTO numbers_input VALUES (20, "2021-07-01 00:00:00.200"), @@ -18,12 +19,13 @@ VALUES -- SQLNESS SLEEP 3s SELECT col_0, window_start, window_end FROM out_num_cnt; +-- SQLNESS SLEEP 500ms INSERT INTO numbers_input VALUES (23,"2021-07-01 00:00:01.000"), (24,"2021-07-01 00:00:01.500"); --- SQLNESS SLEEP 2s +-- SQLNESS SLEEP 3s SELECT col_0, window_start, window_end FROM out_num_cnt; DROP FLOW test_numbers; diff --git a/tests/cases/standalone/common/flow/df_func.result b/tests/cases/standalone/common/flow/df_func.result index 6c08f7854e..9f209a33da 100644 --- a/tests/cases/standalone/common/flow/df_func.result +++ b/tests/cases/standalone/common/flow/df_func.result @@ -15,6 +15,7 @@ SELECT sum(abs(number)) FROM numbers_input_df_func GROUP BY tumble(ts, '1 second Affected Rows: 0 +-- SQLNESS SLEEP 500ms INSERT INTO numbers_input_df_func VALUES (-20, "2021-07-01 00:00:00.200"), @@ -32,6 +33,7 @@ SELECT col_0, window_start, window_end FROM out_num_cnt_df_func; | 42 | 2021-07-01T00:00:00 | 2021-07-01T00:00:01 | +-------+---------------------+---------------------+ +-- SQLNESS SLEEP 500ms INSERT INTO numbers_input_df_func VALUES (23,"2021-07-01 00:00:01.000"), @@ -39,7 +41,7 @@ VALUES Affected Rows: 2 --- SQLNESS SLEEP 2s +-- SQLNESS SLEEP 3s SELECT col_0, window_start, window_end FROM out_num_cnt_df_func; +-------+---------------------+---------------------+ @@ -78,6 +80,7 @@ SELECT abs(sum(number)) FROM numbers_input_df_func GROUP BY tumble(ts, '1 second Affected Rows: 0 +-- SQLNESS SLEEP 500ms INSERT INTO numbers_input_df_func VALUES (-20, "2021-07-01 00:00:00.200"), @@ -95,6 +98,7 @@ SELECT col_0, window_start, window_end FROM out_num_cnt_df_func; | 2 | 2021-07-01T00:00:00 | 2021-07-01T00:00:01 | +-------+---------------------+---------------------+ +-- SQLNESS SLEEP 500ms INSERT INTO numbers_input_df_func VALUES (23,"2021-07-01 00:00:01.000"), @@ -102,7 +106,7 @@ VALUES Affected Rows: 2 --- SQLNESS SLEEP 2s +-- SQLNESS SLEEP 3s SELECT col_0, window_start, window_end FROM out_num_cnt_df_func; +-------+---------------------+---------------------+ @@ -141,6 +145,7 @@ SELECT max(number) - min(number), date_bin(INTERVAL '1 second', ts, '2021-07-01 Affected Rows: 0 +-- SQLNESS SLEEP 500ms INSERT INTO numbers_input VALUES (20, "2021-07-01 00:00:00.200"), @@ -157,6 +162,7 @@ SELECT col_0, col_1 FROM out_num_cnt; | 2 | 2021-07-01T00:00:00 | +-------+---------------------+ +-- SQLNESS SLEEP 500ms INSERT INTO numbers_input VALUES (23,"2021-07-01 00:00:01.000"), @@ -164,7 +170,7 @@ VALUES Affected Rows: 2 --- SQLNESS SLEEP 2s +-- SQLNESS SLEEP 3s SELECT col_0, col_1 FROM out_num_cnt; +-------+---------------------+ @@ -203,6 +209,7 @@ SELECT date_trunc('second', ts), sum(number) FROM numbers_input GROUP BY date_tr Affected Rows: 0 +-- SQLNESS SLEEP 500ms INSERT INTO numbers_input VALUES (20, "2021-07-01 00:00:00.200"), @@ -219,6 +226,7 @@ SELECT col_0, col_1 FROM out_num_cnt; | 2021-07-01T00:00:00 | 42 | +---------------------+-------+ +-- SQLNESS SLEEP 500ms INSERT INTO numbers_input VALUES (23,"2021-07-01 00:00:01.000"), @@ -226,7 +234,7 @@ VALUES Affected Rows: 2 --- SQLNESS SLEEP 2s +-- SQLNESS SLEEP 3s SELECT col_0, col_1 FROM out_num_cnt; +---------------------+-------+ diff --git a/tests/cases/standalone/common/flow/df_func.sql b/tests/cases/standalone/common/flow/df_func.sql index e04d95e477..b3c035a120 100644 --- a/tests/cases/standalone/common/flow/df_func.sql +++ b/tests/cases/standalone/common/flow/df_func.sql @@ -11,6 +11,7 @@ SINK TO out_num_cnt_df_func AS SELECT sum(abs(number)) FROM numbers_input_df_func GROUP BY tumble(ts, '1 second', '2021-07-01 00:00:00'); +-- SQLNESS SLEEP 500ms INSERT INTO numbers_input_df_func VALUES (-20, "2021-07-01 00:00:00.200"), @@ -20,12 +21,13 @@ VALUES -- SQLNESS SLEEP 3s SELECT col_0, window_start, window_end FROM out_num_cnt_df_func; +-- SQLNESS SLEEP 500ms INSERT INTO numbers_input_df_func VALUES (23,"2021-07-01 00:00:01.000"), (-24,"2021-07-01 00:00:01.500"); --- SQLNESS SLEEP 2s +-- SQLNESS SLEEP 3s SELECT col_0, window_start, window_end FROM out_num_cnt_df_func; DROP FLOW test_numbers_df_func; @@ -45,6 +47,7 @@ SINK TO out_num_cnt_df_func AS SELECT abs(sum(number)) FROM numbers_input_df_func GROUP BY tumble(ts, '1 second', '2021-07-01 00:00:00'); +-- SQLNESS SLEEP 500ms INSERT INTO numbers_input_df_func VALUES (-20, "2021-07-01 00:00:00.200"), @@ -54,12 +57,13 @@ VALUES -- SQLNESS SLEEP 3s SELECT col_0, window_start, window_end FROM out_num_cnt_df_func; +-- SQLNESS SLEEP 500ms INSERT INTO numbers_input_df_func VALUES (23,"2021-07-01 00:00:01.000"), (-24,"2021-07-01 00:00:01.500"); --- SQLNESS SLEEP 2s +-- SQLNESS SLEEP 3s SELECT col_0, window_start, window_end FROM out_num_cnt_df_func; DROP FLOW test_numbers_df_func; @@ -79,6 +83,7 @@ SINK TO out_num_cnt AS SELECT max(number) - min(number), date_bin(INTERVAL '1 second', ts, '2021-07-01 00:00:00'::TimestampNanosecond) FROM numbers_input GROUP BY date_bin(INTERVAL '1 second', ts, '2021-07-01 00:00:00'::TimestampNanosecond); +-- SQLNESS SLEEP 500ms INSERT INTO numbers_input VALUES (20, "2021-07-01 00:00:00.200"), @@ -87,12 +92,13 @@ VALUES -- SQLNESS SLEEP 3s SELECT col_0, col_1 FROM out_num_cnt; +-- SQLNESS SLEEP 500ms INSERT INTO numbers_input VALUES (23,"2021-07-01 00:00:01.000"), (24,"2021-07-01 00:00:01.500"); --- SQLNESS SLEEP 2s +-- SQLNESS SLEEP 3s SELECT col_0, col_1 FROM out_num_cnt; DROP FLOW test_numbers; @@ -113,6 +119,7 @@ SINK TO out_num_cnt AS SELECT date_trunc('second', ts), sum(number) FROM numbers_input GROUP BY date_trunc('second', ts); +-- SQLNESS SLEEP 500ms INSERT INTO numbers_input VALUES (20, "2021-07-01 00:00:00.200"), @@ -121,12 +128,13 @@ VALUES -- SQLNESS SLEEP 3s SELECT col_0, col_1 FROM out_num_cnt; +-- SQLNESS SLEEP 500ms INSERT INTO numbers_input VALUES (23,"2021-07-01 00:00:01.000"), (24,"2021-07-01 00:00:01.500"); --- SQLNESS SLEEP 2s +-- SQLNESS SLEEP 3s SELECT col_0, col_1 FROM out_num_cnt; DROP FLOW test_numbers;