mirror of
https://github.com/GreptimeTeam/greptimedb.git
synced 2026-10-28 22:56:19 +00:00
discord9
fe637b04ce
Update the pinned GreptimeTeam/datafusion revision from e3221b8 to cc55344 (the 55.1 fork carrying apache/datafusion#25531 plus a stronger regression test). CastExpr::propagate_constraints used to cast a filter's output interval straight back to the input type. For CAST(k AS BIGINT) = 1 the singleton output [1, 1] was inverted to [1.0, 1.0] although k = 1.5 matches too, so FilterExec advertised k as constant, the equivalence classes dropped the ordering required by ORDER BY k, and rows returned in scan order. The sqlness case keeps every #9600 assertion and the explicit ORDER BY, and adds ascending and descending checks for the partitioned table, the control table and a table whose matching rows are stored in neither ascending nor descending k order. Cargo.lock only rewrites the 35 datafusion source lines. Signed-off-by: discord9 <discord9@163.com>
112 lines
3.5 KiB
SQL
112 lines
3.5 KiB
SQL
CREATE TABLE partition_pruning_cast_partitioned (
|
|
ts TIMESTAMP TIME INDEX,
|
|
k FLOAT PRIMARY KEY,
|
|
v BIGINT,
|
|
)
|
|
PARTITION ON COLUMNS (k) (
|
|
k < 1.25,
|
|
k >= 1.25
|
|
);
|
|
|
|
CREATE TABLE partition_pruning_cast_control (
|
|
ts TIMESTAMP TIME INDEX,
|
|
k FLOAT PRIMARY KEY,
|
|
v BIGINT,
|
|
);
|
|
|
|
INSERT INTO partition_pruning_cast_partitioned VALUES
|
|
(1000, 1.0, 10),
|
|
(1000, 1.5, 15),
|
|
(1000, 2.5, 25);
|
|
INSERT INTO partition_pruning_cast_control VALUES
|
|
(1000, 1.0, 10),
|
|
(1000, 1.5, 15),
|
|
(1000, 2.5, 25);
|
|
|
|
SELECT k, v, CAST(k AS BIGINT) AS cast_k
|
|
FROM partition_pruning_cast_partitioned ORDER BY k;
|
|
SELECT k, v, CAST(k AS BIGINT) AS cast_k
|
|
FROM partition_pruning_cast_control ORDER BY k;
|
|
|
|
-- SQLNESS REPLACE (peers.*) REDACTED
|
|
-- SQLNESS REPLACE (partitioning.*) REDACTED
|
|
EXPLAIN SELECT k, v, CAST(k AS BIGINT) AS cast_k
|
|
FROM partition_pruning_cast_partitioned
|
|
WHERE CAST(k AS BIGINT) = 1;
|
|
|
|
SELECT ts, k, v, CAST(k AS BIGINT) AS cast_k
|
|
FROM partition_pruning_cast_partitioned
|
|
WHERE CAST(k AS BIGINT) = 1
|
|
ORDER BY k;
|
|
SELECT ts, k, v, CAST(k AS BIGINT) AS cast_k
|
|
FROM partition_pruning_cast_control
|
|
WHERE CAST(k AS BIGINT) = 1
|
|
ORDER BY k;
|
|
|
|
-- The same rows must also come back in descending order: a filter on a lossy
|
|
-- cast must not turn `k` into a constant and drop the requested sort.
|
|
SELECT ts, k, v, CAST(k AS BIGINT) AS cast_k
|
|
FROM partition_pruning_cast_partitioned
|
|
WHERE CAST(k AS BIGINT) = 1
|
|
ORDER BY k DESC;
|
|
SELECT ts, k, v, CAST(k AS BIGINT) AS cast_k
|
|
FROM partition_pruning_cast_control
|
|
WHERE CAST(k AS BIGINT) = 1
|
|
ORDER BY k DESC;
|
|
|
|
-- A table whose matching rows are stored in neither ascending nor descending
|
|
-- order, so a dropped sort cannot accidentally satisfy the ASC assertion.
|
|
CREATE TABLE partition_pruning_cast_unsorted (
|
|
ts TIMESTAMP TIME INDEX,
|
|
k FLOAT PRIMARY KEY,
|
|
v BIGINT,
|
|
);
|
|
|
|
INSERT INTO partition_pruning_cast_unsorted VALUES
|
|
(1000, 1.5, 15),
|
|
(1000, 2.5, 25),
|
|
(1000, 1.0, 10),
|
|
(1000, 1.25, 12);
|
|
|
|
SELECT ts, k, v, CAST(k AS BIGINT) AS cast_k
|
|
FROM partition_pruning_cast_unsorted
|
|
WHERE CAST(k AS BIGINT) = 1
|
|
ORDER BY k;
|
|
SELECT ts, k, v, CAST(k AS BIGINT) AS cast_k
|
|
FROM partition_pruning_cast_unsorted
|
|
WHERE CAST(k AS BIGINT) = 1
|
|
ORDER BY k DESC;
|
|
|
|
DROP TABLE partition_pruning_cast_unsorted;
|
|
|
|
-- SQLNESS REPLACE (-+) -
|
|
-- SQLNESS REPLACE (\s\s+) _
|
|
-- SQLNESS REPLACE (elapsed_compute.*) REDACTED
|
|
-- SQLNESS REPLACE (peers.*) REDACTED
|
|
-- SQLNESS REPLACE (metrics.*) REDACTED
|
|
-- SQLNESS REPLACE (partitioning.*) REDACTED
|
|
-- SQLNESS REPLACE region=\d+\(\d+,\s+\d+\) region=REDACTED
|
|
-- SQLNESS REPLACE \\?"(dyn_filters|time_range|file_summary|max_part_range)\\?":.* "$1":REDACTED
|
|
EXPLAIN ANALYZE SELECT k, v
|
|
FROM partition_pruning_cast_partitioned
|
|
WHERE k >= 1.25::FLOAT AND k < 2.5::FLOAT;
|
|
-- SQLNESS REPLACE (-+) -
|
|
-- SQLNESS REPLACE (\s\s+) _
|
|
-- SQLNESS REPLACE (elapsed_compute.*) REDACTED
|
|
-- SQLNESS REPLACE (peers.*) REDACTED
|
|
-- SQLNESS REPLACE (metrics.*) REDACTED
|
|
-- SQLNESS REPLACE (partitioning.*) REDACTED
|
|
-- SQLNESS REPLACE region=\d+\(\d+,\s+\d+\) region=REDACTED
|
|
-- SQLNESS REPLACE \\?"(dyn_filters|time_range|file_summary|max_part_range)\\?":.* "$1":REDACTED
|
|
EXPLAIN ANALYZE SELECT k, v
|
|
FROM partition_pruning_cast_partitioned
|
|
WHERE k >= 1.25::FLOAT AND k < 2.5::FLOAT AND CAST(v AS INT) IS NOT NULL;
|
|
SELECT k, v FROM partition_pruning_cast_partitioned
|
|
WHERE k >= 1.25::FLOAT AND k < 2.5::FLOAT AND CAST(v AS INT) IS NOT NULL;
|
|
|
|
SELECT k FROM partition_pruning_cast_partitioned
|
|
WHERE k = 1.0 OR CAST(k AS BIGINT) = 1 ORDER BY k;
|
|
|
|
DROP TABLE partition_pruning_cast_partitioned;
|
|
DROP TABLE partition_pruning_cast_control;
|