rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-05-16 13:00:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: more sleep when flow insert makes it serial (#4373)

Browse Source 
* tests: more sleep

* fix: wait more time

* fix: update result file
This commit is contained in:
discord9
2024-07-16 11:36:31 +08:00
committed by GitHub
parent 072d7c2022
commit b2c5f8eefa
4 changed files with 30 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
tests/cases/standalone/common/flow/basic.result
View File

@@ -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;
+-------+---------------------+---------------------+

4
tests/cases/standalone/common/flow/basic.sql
View File

@@ -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;

16
tests/cases/standalone/common/flow/df_func.result
View File

@@ -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;
+---------------------+-------+

16
tests/cases/standalone/common/flow/df_func.sql
View File

@@ -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;