fix devive

zhangwenchao-123 · zhangwenchao-123 · commit 2761a5caaf4f · 2025-12-05T18:32:53.000+08:00
diff --git a/src/backend/gporca/libgpopt/src/base/CDrvdPropPlan.cpp b/src/backend/gporca/libgpopt/src/base/CDrvdPropPlan.cpp
@@ -86,7 +86,8 @@ CDrvdPropPlan::Derive(CMemoryPool *mp, CExpressionHandle &exprhdl,
 {
 	CPhysical *popPhysical = CPhysical::PopConvert(exprhdl.Pop());
 	if (nullptr != pdpctxt &&
-		COperator::EopPhysicalCTEConsumer == popPhysical->Eopid())
+		(COperator::EopPhysicalCTEConsumer == popPhysical->Eopid() ||
+		 COperator::EopPhysicalParallelCTEConsumer == popPhysical->Eopid()))
 	{
 		CopyCTEProducerPlanProps(mp, pdpctxt, popPhysical);
 	}

Original file line number	Diff line number	Diff line change
`@@ -86,7 +86,8 @@ CDrvdPropPlan::Derive(CMemoryPool *mp, CExpressionHandle &exprhdl,`
`86`	`86`	`{`
`87`	`87`	`CPhysical *popPhysical = CPhysical::PopConvert(exprhdl.Pop());`
`88`	`88`	`if (nullptr != pdpctxt &&`
`89`		`- COperator::EopPhysicalCTEConsumer == popPhysical->Eopid())`
	`89`	`+ (COperator::EopPhysicalCTEConsumer == popPhysical->Eopid() \|\|`
	`90`	`+ COperator::EopPhysicalParallelCTEConsumer == popPhysical->Eopid()))`
`90`	`91`	`{`
`91`	`92`	`CopyCTEProducerPlanProps(mp, pdpctxt, popPhysical);`
`92`	`93`	`}`