fix enable_parallel

Author: zhangwenchao-123

src/backend/gporca/libgpopt/include/gpopt/xforms/CXformImplementParallelSequence.h

@@ -69,13 +69,8 @@ class CXformImplementParallelSequence : public CXformImplementation
 		return "CXformImplementParallelSequence";
 	}
 
-	// compute xform promise for a given expression handle
-	EXformPromise
-	Exfp(CExpressionHandle &  // exprhdl
-	) const override
-	{
-		return CXform::ExfpHigh;
-	}
+	// compute xform promise for a given expresion handle
+	EXformPromise Exfp(CExpressionHandle &exprhdl) const override;
 
 	// actual transform
 	void Transform(CXformContext *pxfctxt, CXformResult *pxfres,

src/backend/gporca/libgpopt/src/xforms/CXformImplementParallelCTEConsumer.cpp

@@ -34,6 +34,9 @@
 #include "gpopt/operators/CPhysicalParallelCTEConsumer.h"
 
 using namespace gpopt;
+namespace gpdb {
+bool IsParallelModeOK(void);
+}
 
 
 //---------------------------------------------------------------------------
@@ -63,6 +66,12 @@ CXform::EXformPromise
 CXformImplementParallelCTEConsumer::Exfp(CExpressionHandle &  // exprhdl
 ) const
 {
+	// Check if parallel plans are enabled in context and parallel processing in safe
+	if (!gpdb::IsParallelModeOK())
+	{
+		return CXform::ExfpNone;
+	}
+
 	return CXform::ExfpHigh;
 }
 

src/backend/gporca/libgpopt/src/xforms/CXformImplementParallelCTEProducer.cpp

@@ -34,7 +34,9 @@
 #include "gpopt/operators/CPhysicalParallelCTEProducer.h"
 
 using namespace gpopt;
-
+namespace gpdb {
+bool IsParallelModeOK(void);
+}
 
 //---------------------------------------------------------------------------
 //	@function:
@@ -65,6 +67,12 @@ CXform::EXformPromise
 CXformImplementParallelCTEProducer::Exfp(CExpressionHandle &  // exprhdl
 ) const
 {
+	// Check if parallel plans are enabled in context and parallel processing in safe
+	if (!gpdb::IsParallelModeOK())
+	{
+		return CXform::ExfpNone;
+	}
+
 	return CXform::ExfpHigh;
 }
 

src/backend/gporca/libgpopt/src/xforms/CXformImplementParallelSequence.cpp

@@ -35,6 +35,9 @@
 #include "gpopt/operators/CPhysicalParallelSequence.h"
 
 using namespace gpopt;
+namespace gpdb {
+bool IsParallelModeOK(void);
+}
 
 
 //---------------------------------------------------------------------------
@@ -55,6 +58,27 @@ CXformImplementParallelSequence::CXformImplementParallelSequence(CMemoryPool *mp
 }
 
 
+//---------------------------------------------------------------------------
+//	@function:
+//		CXformImplementParallelCTEProducer::Exfp
+//
+//	@doc:
+//		Compute promise of xform
+//
+//---------------------------------------------------------------------------
+CXform::EXformPromise
+CXformImplementParallelSequence::Exfp(CExpressionHandle &  // exprhdl
+) const
+{
+	// Check if parallel plans are enabled in context and parallel processing in safe
+	if (!gpdb::IsParallelModeOK())
+	{
+		return CXform::ExfpNone;
+	}
+
+	return CXform::ExfpHigh;
+}
+
 //---------------------------------------------------------------------------
 //	@function:
 //		CXformImplementParallelSequence::Transform