Skip to content

Commit

Permalink
fix-rt
Browse files Browse the repository at this point in the history
  • Loading branch information
englefly committed Oct 27, 2024
1 parent 763e731 commit ecab9f7
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -7,9 +7,9 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
--------filter((main.k1 = 1))
----------PhysicalOlapScan[test]
--PhysicalResultSink
----hashJoin[INNER_JOIN] hashCondition=((m1.k1 = m2.k1)) otherCondition=() build RFs:RF0 k1->[k1];RF1 k1->[k1]
----hashJoin[INNER_JOIN] hashCondition=((m1.k1 = m2.k1)) otherCondition=()
------filter((temp.k1 = 1))
--------PhysicalCteConsumer ( cteId=CTEId#0 ) apply RFs: RF0 RF1
--------PhysicalCteConsumer ( cteId=CTEId#0 )
------filter((m2.k1 = 1))
--------PhysicalCteConsumer ( cteId=CTEId#0 )

Expand All @@ -21,9 +21,9 @@ PhysicalCteAnchor ( cteId=CTEId#0 )
--------PhysicalQuickSort[LOCAL_SORT]
----------PhysicalOlapScan[test]
--PhysicalResultSink
----hashJoin[INNER_JOIN] hashCondition=((m1.k1 = m2.k1)) otherCondition=() build RFs:RF0 k1->[k1];RF1 k1->[k1]
----hashJoin[INNER_JOIN] hashCondition=((m1.k1 = m2.k1)) otherCondition=()
------filter((temp.k1 = 1))
--------PhysicalCteConsumer ( cteId=CTEId#0 ) apply RFs: RF0 RF1
--------PhysicalCteConsumer ( cteId=CTEId#0 )
------filter((m2.k1 = 1))
--------PhysicalCteConsumer ( cteId=CTEId#0 )

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,8 +19,9 @@ suite("test_cte_filter_pushdown") {
sql "SET enable_pipeline_engine=true"
sql "SET enable_fallback_to_original_planner=false"
sql "set ignore_shape_nodes='PhysicalDistribute, PhysicalProject'"
sql "set runtime_filter_mode=global;"
sql "set runtime_filter_type=12;"
sql "set runtime_filter_mode=off;"


// CTE filter pushing down with the same filter
qt_cte_filter_pushdown_1 """
explain shape plan
Expand Down

0 comments on commit ecab9f7

Please sign in to comment.