This is an automated email from the ASF dual-hosted git repository. fanfuxiaoran pushed a commit to branch fix_orca in repository https://gitbox.apache.org/repos/asf/cloudberry.git
commit ff462dee4f99fd12f20e61ca2041770d9dbca3fd Author: wangxiaoran <[email protected]> AuthorDate: Fri Mar 7 17:18:56 2025 +0800 Try to fix the issue https://github.com/apache/cloudberry/issues/854 --- .../gporca/libgpopt/src/operators/CPhysicalHashJoin.cpp | 13 ++----------- 1 file changed, 2 insertions(+), 11 deletions(-) diff --git a/src/backend/gporca/libgpopt/src/operators/CPhysicalHashJoin.cpp b/src/backend/gporca/libgpopt/src/operators/CPhysicalHashJoin.cpp index c398cd95f3..c50b77d718 100644 --- a/src/backend/gporca/libgpopt/src/operators/CPhysicalHashJoin.cpp +++ b/src/backend/gporca/libgpopt/src/operators/CPhysicalHashJoin.cpp @@ -1172,6 +1172,7 @@ CPhysicalHashJoin::CreateOptRequests(CMemoryPool *mp) ULONG ulDistrReqs = GPOPT_NON_HASH_DIST_REQUESTS + m_pdrgpdsRedistributeRequests->Size(); SetDistrRequests(ulDistrReqs); + SetPartPropagateRequests(2); // With DP enabled, there are several (max 10 controlled by macro) // alternatives generated for a join tree and during optimization of those @@ -1194,17 +1195,7 @@ CPhysicalHashJoin::CreateOptRequests(CMemoryPool *mp) // some cases, but can create better alternatives to DPE, so // we also generate this additional request for expressions that originated // from CXformExpandNAryJoinGreedy. - CPhysicalJoin *physical_join = dynamic_cast<CPhysicalJoin *>(this); - if ((GPOPT_FDISABLED_XFORM(CXform::ExfExpandNAryJoinDP) && - GPOPT_FDISABLED_XFORM(CXform::ExfExpandNAryJoinDPv2)) || - physical_join->OriginXform() == CXform::ExfExpandNAryJoinGreedy) - { - SetPartPropagateRequests(2); - } - else - { - SetPartPropagateRequests(1); - } + SetPartPropagateRequests(2); } CExpression * --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
