postgres/timescaledb
1
0
Fork 0
mirror of https://github.com/timescale/timescaledb.git synced 2025-05-22 05:31:41 +08:00
Code Issues Packages Projects Releases Wiki Activity

Add missing order by to compression_ddl tests

Browse Source 
Some queries in compression_ddl had no order by. Therefore the output
order was not defined, which led to flaky tests.
This commit is contained in:
Jan Nidzwetzki 2023-04-21 15:00:10 +02:00 committed by Jan Nidzwetzki
parent 583c36e91e
commit c54d8bd946
2 changed files with 171 additions and 131 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

257
tsl/test/expected/compression_ddl.out
View File

@ -1457,27 +1457,31 @@ AND time <= '2000-01-05 23:55:00+0';
SET enable_seqscan = off; SET enable_seqscan = off;
EXPLAIN (costs off) SELECT device_id, count(*) EXPLAIN (costs off) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
QUERY PLAN ORDER BY device_id;
----------------------------------------------------------------------------------------------------------------------------------- QUERY PLAN
HashAggregate -----------------------------------------------------------------------------------------------------------------------------------------
Group Key: _hyper_31_107_chunk.device_id Sort
-> Append Sort Key: _hyper_31_107_chunk.device_id
-> Custom Scan (DecompressChunk) on _hyper_31_107_chunk -> HashAggregate
-> Index Scan using compress_hyper_32_108_chunk__compressed_hypertable_32_device_id on compress_hyper_32_108_chunk Group Key: _hyper_31_107_chunk.device_id
-> Index Only Scan using _hyper_31_107_chunk_compression_insert_device_id_time_idx on _hyper_31_107_chunk -> Append
(6 rows) -> Custom Scan (DecompressChunk) on _hyper_31_107_chunk
-> Index Scan using compress_hyper_32_108_chunk__compressed_hypertable_32_device_id on compress_hyper_32_108_chunk
-> Index Only Scan using _hyper_31_107_chunk_compression_insert_device_id_time_idx on _hyper_31_107_chunk
(8 rows)
SELECT device_id, count(*) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
ORDER BY device_id;
device_id | count device_id | count
-----------+------- -----------+-------
3 | 3596
5 | 3596
4 | 3596
2 | 3596
1 | 3596 1 | 3596
2 | 3596
3 | 3596
4 | 3596
5 | 3596
(5 rows) (5 rows)
CALL recompress_chunk(:'CHUNK_NAME'::regclass); CALL recompress_chunk(:'CHUNK_NAME'::regclass);
@ -1492,7 +1496,8 @@ AND time <= '2000-01-05 23:55:00+0';
SELECT device_id, count(*) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
ORDER BY device_id;
device_id | count device_id | count
-----------+------- -----------+-------
1 | 3596 1 | 3596
@ -1530,29 +1535,33 @@ AND time <= '2000-01-11 23:55:00+0';
SET enable_seqscan = off; SET enable_seqscan = off;
EXPLAIN (costs off) SELECT device_id, count(*) EXPLAIN (costs off) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
QUERY PLAN ORDER BY device_id;
----------------------------------------------------------------------------------------------------------------------------------- QUERY PLAN
HashAggregate -----------------------------------------------------------------------------------------------------------------------------------------
Group Key: _hyper_31_107_chunk.device_id Sort
-> Append Sort Key: _hyper_31_107_chunk.device_id
-> Custom Scan (DecompressChunk) on _hyper_31_107_chunk -> HashAggregate
-> Index Scan using compress_hyper_32_108_chunk__compressed_hypertable_32_device_id on compress_hyper_32_108_chunk Group Key: _hyper_31_107_chunk.device_id
-> Custom Scan (DecompressChunk) on _hyper_31_109_chunk -> Append
-> Index Scan using compress_hyper_32_110_chunk__compressed_hypertable_32_device_id on compress_hyper_32_110_chunk -> Custom Scan (DecompressChunk) on _hyper_31_107_chunk
-> Index Only Scan using _hyper_31_109_chunk_compression_insert_device_id_time_idx on _hyper_31_109_chunk -> Index Scan using compress_hyper_32_108_chunk__compressed_hypertable_32_device_id on compress_hyper_32_108_chunk
(8 rows) -> Custom Scan (DecompressChunk) on _hyper_31_109_chunk
-> Index Scan using compress_hyper_32_110_chunk__compressed_hypertable_32_device_id on compress_hyper_32_110_chunk
-> Index Only Scan using _hyper_31_109_chunk_compression_insert_device_id_time_idx on _hyper_31_109_chunk
(10 rows)
SELECT device_id, count(*) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
ORDER BY device_id;
device_id | count device_id | count
-----------+------- -----------+-------
3 | 7192
5 | 7192
4 | 7192
2 | 7192
1 | 7192 1 | 7192
2 | 7192
3 | 7192
4 | 7192
5 | 7192
(5 rows) (5 rows)
CALL recompress_chunk(:'CHUNK_NAME'::regclass); CALL recompress_chunk(:'CHUNK_NAME'::regclass);
@ -1567,14 +1576,15 @@ AND time <= '2000-01-11 23:55:00+0';
SELECT device_id, count(*) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
ORDER BY device_id;
device_id | count device_id | count
-----------+------- -----------+-------
3 | 7192
5 | 7192
4 | 7192
2 | 7192
1 | 7192 1 | 7192
2 | 7192
3 | 7192
4 | 7192
5 | 7192
(5 rows) (5 rows)
SET enable_seqscan = default; SET enable_seqscan = default;
@ -1605,31 +1615,35 @@ AND time <= '2000-01-19 23:55:00+0';
SET enable_seqscan = off; SET enable_seqscan = off;
EXPLAIN (costs off) SELECT device_id, count(*) EXPLAIN (costs off) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
QUERY PLAN ORDER BY device_id;
----------------------------------------------------------------------------------------------------------------------------------- QUERY PLAN
HashAggregate -----------------------------------------------------------------------------------------------------------------------------------------
Group Key: _hyper_31_107_chunk.device_id Sort
-> Append Sort Key: _hyper_31_107_chunk.device_id
-> Custom Scan (DecompressChunk) on _hyper_31_107_chunk -> HashAggregate
-> Index Scan using compress_hyper_32_108_chunk__compressed_hypertable_32_device_id on compress_hyper_32_108_chunk Group Key: _hyper_31_107_chunk.device_id
-> Custom Scan (DecompressChunk) on _hyper_31_109_chunk -> Append
-> Index Scan using compress_hyper_32_110_chunk__compressed_hypertable_32_device_id on compress_hyper_32_110_chunk -> Custom Scan (DecompressChunk) on _hyper_31_107_chunk
-> Custom Scan (DecompressChunk) on _hyper_31_111_chunk -> Index Scan using compress_hyper_32_108_chunk__compressed_hypertable_32_device_id on compress_hyper_32_108_chunk
-> Index Scan using compress_hyper_32_112_chunk__compressed_hypertable_32_device_id on compress_hyper_32_112_chunk -> Custom Scan (DecompressChunk) on _hyper_31_109_chunk
-> Index Only Scan using _hyper_31_111_chunk_compression_insert_device_id_time_idx on _hyper_31_111_chunk -> Index Scan using compress_hyper_32_110_chunk__compressed_hypertable_32_device_id on compress_hyper_32_110_chunk
(10 rows) -> Custom Scan (DecompressChunk) on _hyper_31_111_chunk
-> Index Scan using compress_hyper_32_112_chunk__compressed_hypertable_32_device_id on compress_hyper_32_112_chunk
-> Index Only Scan using _hyper_31_111_chunk_compression_insert_device_id_time_idx on _hyper_31_111_chunk
(12 rows)
SELECT device_id, count(*) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
ORDER BY device_id;
device_id | count device_id | count
-----------+------- -----------+-------
3 | 10788
5 | 10788
4 | 10788
2 | 10788
1 | 10788 1 | 10788
2 | 10788
3 | 10788
4 | 10788
5 | 10788
(5 rows) (5 rows)
CALL recompress_chunk(:'CHUNK_NAME'::regclass); CALL recompress_chunk(:'CHUNK_NAME'::regclass);
@ -1644,14 +1658,15 @@ AND time <= '2000-01-19 23:55:00+0';
SELECT device_id, count(*) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
ORDER BY device_id;
device_id | count device_id | count
-----------+------- -----------+-------
3 | 10788
5 | 10788
4 | 10788
2 | 10788
1 | 10788 1 | 10788
2 | 10788
3 | 10788
4 | 10788
5 | 10788
(5 rows) (5 rows)
SET enable_seqscan = default; SET enable_seqscan = default;
@ -1682,33 +1697,37 @@ AND time <= '2000-01-26 23:55:00+0';
SET enable_seqscan = off; SET enable_seqscan = off;
EXPLAIN (costs off) SELECT device_id, count(*) EXPLAIN (costs off) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
QUERY PLAN ORDER BY device_id;
----------------------------------------------------------------------------------------------------------------------------------- QUERY PLAN
HashAggregate -----------------------------------------------------------------------------------------------------------------------------------------
Group Key: _hyper_31_107_chunk.device_id Sort
-> Append Sort Key: _hyper_31_107_chunk.device_id
-> Custom Scan (DecompressChunk) on _hyper_31_107_chunk -> HashAggregate
-> Index Scan using compress_hyper_32_108_chunk__compressed_hypertable_32_device_id on compress_hyper_32_108_chunk Group Key: _hyper_31_107_chunk.device_id
-> Custom Scan (DecompressChunk) on _hyper_31_109_chunk -> Append
-> Index Scan using compress_hyper_32_110_chunk__compressed_hypertable_32_device_id on compress_hyper_32_110_chunk -> Custom Scan (DecompressChunk) on _hyper_31_107_chunk
-> Custom Scan (DecompressChunk) on _hyper_31_111_chunk -> Index Scan using compress_hyper_32_108_chunk__compressed_hypertable_32_device_id on compress_hyper_32_108_chunk
-> Index Scan using compress_hyper_32_112_chunk__compressed_hypertable_32_device_id on compress_hyper_32_112_chunk -> Custom Scan (DecompressChunk) on _hyper_31_109_chunk
-> Custom Scan (DecompressChunk) on _hyper_31_113_chunk -> Index Scan using compress_hyper_32_110_chunk__compressed_hypertable_32_device_id on compress_hyper_32_110_chunk
-> Index Scan using compress_hyper_32_114_chunk__compressed_hypertable_32_device_id on compress_hyper_32_114_chunk -> Custom Scan (DecompressChunk) on _hyper_31_111_chunk
-> Index Only Scan using _hyper_31_113_chunk_compression_insert_device_id_time_idx on _hyper_31_113_chunk -> Index Scan using compress_hyper_32_112_chunk__compressed_hypertable_32_device_id on compress_hyper_32_112_chunk
(12 rows) -> Custom Scan (DecompressChunk) on _hyper_31_113_chunk
-> Index Scan using compress_hyper_32_114_chunk__compressed_hypertable_32_device_id on compress_hyper_32_114_chunk
-> Index Only Scan using _hyper_31_113_chunk_compression_insert_device_id_time_idx on _hyper_31_113_chunk
(14 rows)
SELECT device_id, count(*) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
ORDER BY device_id;
device_id | count device_id | count
-----------+------- -----------+-------
3 | 14384
5 | 14384
4 | 14384
2 | 14384
1 | 14384 1 | 14384
2 | 14384
3 | 14384
4 | 14384
5 | 14384
(5 rows) (5 rows)
CALL recompress_chunk(:'CHUNK_NAME'::regclass); CALL recompress_chunk(:'CHUNK_NAME'::regclass);
@ -1723,14 +1742,15 @@ AND time <= '2000-01-26 23:55:00+0';
SELECT device_id, count(*) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
ORDER BY device_id;
device_id | count device_id | count
-----------+------- -----------+-------
3 | 14384
5 | 14384
4 | 14384
2 | 14384
1 | 14384 1 | 14384
2 | 14384
3 | 14384
4 | 14384
5 | 14384
(5 rows) (5 rows)
SET enable_seqscan = default; SET enable_seqscan = default;
@ -1761,35 +1781,39 @@ AND time <= '2000-02-01 23:55:00+0';
SET enable_seqscan = off; SET enable_seqscan = off;
EXPLAIN (costs off) SELECT device_id, count(*) EXPLAIN (costs off) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
QUERY PLAN ORDER BY device_id;
----------------------------------------------------------------------------------------------------------------------------------- QUERY PLAN
HashAggregate -----------------------------------------------------------------------------------------------------------------------------------------
Group Key: _hyper_31_107_chunk.device_id Sort
-> Append Sort Key: _hyper_31_107_chunk.device_id
-> Custom Scan (DecompressChunk) on _hyper_31_107_chunk -> HashAggregate
-> Index Scan using compress_hyper_32_108_chunk__compressed_hypertable_32_device_id on compress_hyper_32_108_chunk Group Key: _hyper_31_107_chunk.device_id
-> Custom Scan (DecompressChunk) on _hyper_31_109_chunk -> Append
-> Index Scan using compress_hyper_32_110_chunk__compressed_hypertable_32_device_id on compress_hyper_32_110_chunk -> Custom Scan (DecompressChunk) on _hyper_31_107_chunk
-> Custom Scan (DecompressChunk) on _hyper_31_111_chunk -> Index Scan using compress_hyper_32_108_chunk__compressed_hypertable_32_device_id on compress_hyper_32_108_chunk
-> Index Scan using compress_hyper_32_112_chunk__compressed_hypertable_32_device_id on compress_hyper_32_112_chunk -> Custom Scan (DecompressChunk) on _hyper_31_109_chunk
-> Custom Scan (DecompressChunk) on _hyper_31_113_chunk -> Index Scan using compress_hyper_32_110_chunk__compressed_hypertable_32_device_id on compress_hyper_32_110_chunk
-> Index Scan using compress_hyper_32_114_chunk__compressed_hypertable_32_device_id on compress_hyper_32_114_chunk -> Custom Scan (DecompressChunk) on _hyper_31_111_chunk
-> Custom Scan (DecompressChunk) on _hyper_31_115_chunk -> Index Scan using compress_hyper_32_112_chunk__compressed_hypertable_32_device_id on compress_hyper_32_112_chunk
-> Index Scan using compress_hyper_32_116_chunk__compressed_hypertable_32_device_id on compress_hyper_32_116_chunk -> Custom Scan (DecompressChunk) on _hyper_31_113_chunk
-> Index Only Scan using _hyper_31_115_chunk_compression_insert_device_id_time_idx on _hyper_31_115_chunk -> Index Scan using compress_hyper_32_114_chunk__compressed_hypertable_32_device_id on compress_hyper_32_114_chunk
(14 rows) -> Custom Scan (DecompressChunk) on _hyper_31_115_chunk
-> Index Scan using compress_hyper_32_116_chunk__compressed_hypertable_32_device_id on compress_hyper_32_116_chunk
-> Index Only Scan using _hyper_31_115_chunk_compression_insert_device_id_time_idx on _hyper_31_115_chunk
(16 rows)
SELECT device_id, count(*) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
ORDER BY device_id;
device_id | count device_id | count
-----------+------- -----------+-------
3 | 17980
5 | 17980
4 | 17980
2 | 17980
1 | 17980 1 | 17980
2 | 17980
3 | 17980
4 | 17980
5 | 17980
(5 rows) (5 rows)
CALL recompress_chunk(:'CHUNK_NAME'::regclass); CALL recompress_chunk(:'CHUNK_NAME'::regclass);
@ -1804,14 +1828,15 @@ AND time <= '2000-02-01 23:55:00+0';
SELECT device_id, count(*) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
ORDER BY device_id;
device_id | count device_id | count
-----------+------- -----------+-------
3 | 17980
5 | 17980
4 | 17980
2 | 17980
1 | 17980 1 | 17980
2 | 17980
3 | 17980
4 | 17980
5 | 17980
(5 rows) (5 rows)
SET enable_seqscan = default; SET enable_seqscan = default;

45
tsl/test/sql/compression_ddl.sql
View File

@ -656,10 +656,12 @@ AND time <= '2000-01-05 23:55:00+0';
SET enable_seqscan = off; SET enable_seqscan = off;
EXPLAIN (costs off) SELECT device_id, count(*) EXPLAIN (costs off) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
ORDER BY device_id;
SELECT device_id, count(*) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
ORDER BY device_id;
CALL recompress_chunk(:'CHUNK_NAME'::regclass); CALL recompress_chunk(:'CHUNK_NAME'::regclass);
SELECT count(*), sum(v0), sum(v1), sum(v2), sum(v3) SELECT count(*), sum(v0), sum(v1), sum(v2), sum(v3)
FROM compression_insert FROM compression_insert
@ -667,7 +669,8 @@ WHERE time >= '2000-01-01 0:00:00+0'
AND time <= '2000-01-05 23:55:00+0'; AND time <= '2000-01-05 23:55:00+0';
SELECT device_id, count(*) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
ORDER BY device_id;
SET enable_seqscan = default; SET enable_seqscan = default;
-- 1. drop column after first insert into chunk, before compressing -- 1. drop column after first insert into chunk, before compressing
@ -696,10 +699,12 @@ AND time <= '2000-01-11 23:55:00+0';
SET enable_seqscan = off; SET enable_seqscan = off;
EXPLAIN (costs off) SELECT device_id, count(*) EXPLAIN (costs off) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
ORDER BY device_id;
SELECT device_id, count(*) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
ORDER BY device_id;
CALL recompress_chunk(:'CHUNK_NAME'::regclass); CALL recompress_chunk(:'CHUNK_NAME'::regclass);
SELECT count(*), sum(v0), sum(v1), sum(v2), sum(v3) SELECT count(*), sum(v0), sum(v1), sum(v2), sum(v3)
FROM compression_insert FROM compression_insert
@ -707,7 +712,8 @@ WHERE time >= '2000-01-07 0:00:00+0'
AND time <= '2000-01-11 23:55:00+0'; AND time <= '2000-01-11 23:55:00+0';
SELECT device_id, count(*) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
ORDER BY device_id;
SET enable_seqscan = default; SET enable_seqscan = default;
-- 2. drop column after compressing chunk -- 2. drop column after compressing chunk
@ -735,10 +741,12 @@ AND time <= '2000-01-19 23:55:00+0';
SET enable_seqscan = off; SET enable_seqscan = off;
EXPLAIN (costs off) SELECT device_id, count(*) EXPLAIN (costs off) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
ORDER BY device_id;
SELECT device_id, count(*) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
ORDER BY device_id;
CALL recompress_chunk(:'CHUNK_NAME'::regclass); CALL recompress_chunk(:'CHUNK_NAME'::regclass);
SELECT count(*), sum(v0), sum(v1), sum(v2), sum(v3) SELECT count(*), sum(v0), sum(v1), sum(v2), sum(v3)
FROM compression_insert FROM compression_insert
@ -746,7 +754,8 @@ WHERE time >= '2000-01-15 0:00:00+0'
AND time <= '2000-01-19 23:55:00+0'; AND time <= '2000-01-19 23:55:00+0';
SELECT device_id, count(*) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
ORDER BY device_id;
SET enable_seqscan = default; SET enable_seqscan = default;
-- 3. add new column after first insert into chunk, before compressing -- 3. add new column after first insert into chunk, before compressing
@ -774,10 +783,12 @@ AND time <= '2000-01-26 23:55:00+0';
SET enable_seqscan = off; SET enable_seqscan = off;
EXPLAIN (costs off) SELECT device_id, count(*) EXPLAIN (costs off) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
ORDER BY device_id;
SELECT device_id, count(*) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
ORDER BY device_id;
CALL recompress_chunk(:'CHUNK_NAME'::regclass); CALL recompress_chunk(:'CHUNK_NAME'::regclass);
SELECT count(*), sum(v0), sum(v1), sum(v2), sum(v3) SELECT count(*), sum(v0), sum(v1), sum(v2), sum(v3)
FROM compression_insert FROM compression_insert
@ -785,7 +796,8 @@ WHERE time >= '2000-01-22 0:00:00+0'
AND time <= '2000-01-26 23:55:00+0'; AND time <= '2000-01-26 23:55:00+0';
SELECT device_id, count(*) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
ORDER BY device_id;
SET enable_seqscan = default; SET enable_seqscan = default;
-- 4. add new column after compressing chunk -- 4. add new column after compressing chunk
@ -812,10 +824,12 @@ AND time <= '2000-02-01 23:55:00+0';
SET enable_seqscan = off; SET enable_seqscan = off;
EXPLAIN (costs off) SELECT device_id, count(*) EXPLAIN (costs off) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
ORDER BY device_id;
SELECT device_id, count(*) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
ORDER BY device_id;
CALL recompress_chunk(:'CHUNK_NAME'::regclass); CALL recompress_chunk(:'CHUNK_NAME'::regclass);
SELECT count(*), sum(v0), sum(v1), sum(v2), sum(v3) SELECT count(*), sum(v0), sum(v1), sum(v2), sum(v3)
FROM compression_insert FROM compression_insert
@ -823,7 +837,8 @@ WHERE time >= '2000-01-28 0:00:00+0'
AND time <= '2000-02-01 23:55:00+0'; AND time <= '2000-02-01 23:55:00+0';
SELECT device_id, count(*) SELECT device_id, count(*)
FROM compression_insert FROM compression_insert
GROUP BY device_id; GROUP BY device_id
ORDER BY device_id;
SET enable_seqscan = default; SET enable_seqscan = default;
DROP TABLE compression_insert; DROP TABLE compression_insert;