This is an automated email from the ASF dual-hosted git repository. tuhaihe pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/cloudberry.git
commit 43f4903cc957abce4ffebc0c78b9d67b9d4e53f5 Author: liushengsong <[email protected]> AuthorDate: Fri May 22 18:18:30 2026 +0800 Enable ORCA runtime filter pushdown tests in gp_runtime_filter ORCA now correctly supports runtime filter pushdown, so uncomment the previously disabled test block that verifies pushdown behavior with optimizer on. --- src/test/regress/expected/gp_runtime_filter.out | 44 ++++++++++++++++++++----- src/test/regress/sql/gp_runtime_filter.sql | 17 +++++----- 2 files changed, 43 insertions(+), 18 deletions(-) diff --git a/src/test/regress/expected/gp_runtime_filter.out b/src/test/regress/expected/gp_runtime_filter.out index cefb41ed56a..ff22732200e 100644 --- a/src/test/regress/expected/gp_runtime_filter.out +++ b/src/test/regress/expected/gp_runtime_filter.out @@ -429,15 +429,41 @@ INSERT INTO t1 SELECT * FROM t1; INSERT INTO t1 SELECT * FROM t1; INSERT INTO t2 select * FROM t2; ANALYZE; --- MERGE16_FIXME: enable these tests after the fix of orca --- SET optimizer TO on; --- SET gp_enable_runtime_filter_pushdown TO off; --- EXPLAIN (ANALYZE, COSTS OFF, SUMMARY OFF, TIMING OFF) SELECT t1.c3 FROM t1, t2 WHERE t1.c1 = t2.c1; --- --- SET gp_enable_runtime_filter_pushdown TO on; --- EXPLAIN (ANALYZE, COSTS OFF, SUMMARY OFF, TIMING OFF) SELECT t1.c3 FROM t1, t2 WHERE t1.c1 = t2.c1; --- --- RESET gp_enable_runtime_filter_pushdown; +SET optimizer TO on; +SET gp_enable_runtime_filter_pushdown TO off; +EXPLAIN (ANALYZE, COSTS OFF, SUMMARY OFF, TIMING OFF) SELECT t1.c3 FROM t1, t2 WHERE t1.c1 = t2.c1; + QUERY PLAN +------------------------------------------------------------------------------------------- + Gather Motion 3:1 (slice1; segments: 3) (actual rows=32 loops=1) + -> Hash Join (actual rows=32 loops=1) + Hash Cond: (t1.c1 = t2.c1) + Extra Text: (seg0) Hash chain length 2.0 avg, 2 max, using 3 of 524288 buckets. + -> Result (actual rows=16 loops=1) + -> Seq Scan on t1 (actual rows=24 loops=1) + -> Hash (actual rows=6 loops=1) + Buckets: 524288 Batches: 1 Memory Usage: 4097kB + -> Seq Scan on t2 (actual rows=6 loops=1) + Optimizer: GPORCA +(10 rows) + +SET gp_enable_runtime_filter_pushdown TO on; +EXPLAIN (ANALYZE, COSTS OFF, SUMMARY OFF, TIMING OFF) SELECT t1.c3 FROM t1, t2 WHERE t1.c1 = t2.c1; + QUERY PLAN +------------------------------------------------------------------------------------------- + Gather Motion 3:1 (slice1; segments: 3) (actual rows=32 loops=1) + -> Hash Join (actual rows=32 loops=1) + Hash Cond: (t1.c1 = t2.c1) + Extra Text: (seg0) Hash chain length 2.0 avg, 2 max, using 3 of 524288 buckets. + -> Result (actual rows=16 loops=1) + -> Seq Scan on t1 (actual rows=16 loops=1) + Rows Removed by Pushdown Runtime Filter: 8 + -> Hash (actual rows=6 loops=1) + Buckets: 524288 Batches: 1 Memory Usage: 4097kB + -> Seq Scan on t2 (actual rows=6 loops=1) + Optimizer: GPORCA +(11 rows) + +RESET gp_enable_runtime_filter_pushdown; DROP TABLE IF EXISTS t1; DROP TABLE IF EXISTS t2; -- case 6: hashjoin + hashjoin + seqscan diff --git a/src/test/regress/sql/gp_runtime_filter.sql b/src/test/regress/sql/gp_runtime_filter.sql index 227d8a64c98..d221c04958e 100644 --- a/src/test/regress/sql/gp_runtime_filter.sql +++ b/src/test/regress/sql/gp_runtime_filter.sql @@ -183,15 +183,14 @@ INSERT INTO t1 SELECT * FROM t1; INSERT INTO t2 select * FROM t2; ANALYZE; --- MERGE16_FIXME: enable these tests after the fix of orca --- SET optimizer TO on; --- SET gp_enable_runtime_filter_pushdown TO off; --- EXPLAIN (ANALYZE, COSTS OFF, SUMMARY OFF, TIMING OFF) SELECT t1.c3 FROM t1, t2 WHERE t1.c1 = t2.c1; --- --- SET gp_enable_runtime_filter_pushdown TO on; --- EXPLAIN (ANALYZE, COSTS OFF, SUMMARY OFF, TIMING OFF) SELECT t1.c3 FROM t1, t2 WHERE t1.c1 = t2.c1; --- --- RESET gp_enable_runtime_filter_pushdown; +SET optimizer TO on; +SET gp_enable_runtime_filter_pushdown TO off; +EXPLAIN (ANALYZE, COSTS OFF, SUMMARY OFF, TIMING OFF) SELECT t1.c3 FROM t1, t2 WHERE t1.c1 = t2.c1; + +SET gp_enable_runtime_filter_pushdown TO on; +EXPLAIN (ANALYZE, COSTS OFF, SUMMARY OFF, TIMING OFF) SELECT t1.c3 FROM t1, t2 WHERE t1.c1 = t2.c1; + +RESET gp_enable_runtime_filter_pushdown; DROP TABLE IF EXISTS t1; DROP TABLE IF EXISTS t2; --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
