Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

fix(ci): flaky test #17090

Merged
merged 1 commit into from
Dec 20, 2024
Merged

fix(ci): flaky test #17090

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
48 changes: 22 additions & 26 deletions tests/sqllogictests/suites/mode/cluster/shuffle.test
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -20,23 +20,23 @@ query T
explain select * from (select t1.number, t2.number from t1 right outer join (SELECT number FROM t2 QUALIFY row_number() OVER ( PARTITION BY number ORDER BY number DESC ) = 1) AS t2 ON t1.number = t2.number) as tt(a, b) order by a;
----
Sort
├── output columns: [a (#3), t2.number (#1)]
├── sort keys: [a ASC NULLS LAST]
├── estimated rows: 0.03
├── output columns: [t1.number (#0), t2.number (#1)]
├── sort keys: [number ASC NULLS LAST]
├── estimated rows: 0.01
└── Exchange
├── output columns: [a (#3), t2.number (#1), #_order_col]
├── output columns: [t1.number (#0), t2.number (#1), #_order_col]
├── exchange type: Merge
└── Sort
├── output columns: [a (#3), t2.number (#1), #_order_col]
├── sort keys: [a ASC NULLS LAST]
├── estimated rows: 0.03
├── output columns: [t1.number (#0), t2.number (#1), #_order_col]
├── sort keys: [number ASC NULLS LAST]
├── estimated rows: 0.01
└── HashJoin
├── output columns: [a (#3), t2.number (#1)]
├── output columns: [t1.number (#0), t2.number (#1)]
├── join type: RIGHT OUTER
├── build keys: [t2.number (#1)]
├── probe keys: [t1.number (#3)]
├── probe keys: [t1.number (#0)]
├── filters: []
├── estimated rows: 0.03
├── estimated rows: 0.01
├── Filter(Build)
│ ├── output columns: [t2.number (#1)]
│ ├── filters: [row_number() OVER ( PARTITION BY number ORDER BY number DESC ) (#2) = 1]
Expand Down Expand Up @@ -65,22 +65,18 @@ Sort
│ ├── push downs: [filters: [], limit: NONE]
│ └── estimated rows: 14.00
└── Exchange(Probe)
├── output columns: [a (#3)]
├── exchange type: Hash(t1.number (#3))
└── EvalScalar
├── output columns: [a (#3)]
├── expressions: [CAST(t1.number (#0) AS UInt64 NULL)]
├── estimated rows: 5.00
└── TableScan
├── table: default.default.t1
├── output columns: [number (#0)]
├── read rows: 5
├── read size: < 1 KiB
├── partitions total: 3
├── partitions scanned: 3
├── pruning stats: [segments: <range pruning: 1 to 1>, blocks: <range pruning: 3 to 3>]
├── push downs: [filters: [], limit: NONE]
└── estimated rows: 5.00
├── output columns: [t1.number (#0)]
├── exchange type: Hash(t1.number (#0))
└── TableScan
├── table: default.default.t1
├── output columns: [number (#0)]
├── read rows: 5
├── read size: < 1 KiB
├── partitions total: 3
├── partitions scanned: 3
├── pruning stats: [segments: <range pruning: 1 to 1>, blocks: <range pruning: 3 to 3>]
├── push downs: [filters: [], limit: NONE]
└── estimated rows: 5.00

statement ok
drop table if exists t1;
Expand Down
30 changes: 13 additions & 17 deletions ...standalone/explain/push_down_filter/push_down_filter_join/push_down_filter_self_join.test
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -12,25 +12,21 @@ D as (select * from C)
select * from D;
----
HashJoin
├── output columns: [a.a (#0), a.b (#1), b (#5), a (#4)]
├── output columns: [a.a (#0), a.b (#1), a.b (#3), a.a (#2)]
├── join type: INNER
├── build keys: [b2.a (#4)]
├── probe keys: [CAST(b1.a (#0) AS UInt64 NULL)]
├── filters: [CAST(d.b (#1) AS UInt64 NULL) < d.b (#5)]
├── build keys: [b2.a (#2)]
├── probe keys: [b1.a (#0)]
├── filters: [d.b (#1) < d.b (#3)]
├── estimated rows: 400.00
├── EvalScalar(Build)
│ ├── output columns: [a (#4), b (#5)]
│ ├── expressions: [CAST(b2.a (#2) AS UInt64 NULL), CAST(b2.b (#3) AS UInt64 NULL)]
│ ├── estimated rows: 20.00
│ └── TableScan
│ ├── table: default.default.a
│ ├── output columns: [a (#2), b (#3)]
│ ├── read rows: 20
│ ├── read size: < 1 KiB
│ ├── partitions total: 0
│ ├── partitions scanned: 0
│ ├── push downs: [filters: [], limit: NONE]
│ └── estimated rows: 20.00
├── TableScan(Build)
│ ├── table: default.default.a
│ ├── output columns: [a (#2), b (#3)]
│ ├── read rows: 20
│ ├── read size: < 1 KiB
│ ├── partitions total: 0
│ ├── partitions scanned: 0
│ ├── push downs: [filters: [], limit: NONE]
│ └── estimated rows: 20.00
└── TableScan(Probe)
├── table: default.default.a
├── output columns: [a (#0), b (#1)]
Expand Down
Loading