fix: Fix the UnionExec match branches in CometExecRule (apache#68)

wankunde · web-flow · commit 97ed2b8a39a2 · 2024-02-21T07:48:34.000-08:00
diff --git a/spark/src/main/scala/org/apache/comet/CometSparkSessionExtensions.scala b/spark/src/main/scala/org/apache/comet/CometSparkSessionExtensions.scala
@@ -327,6 +327,8 @@ class CometSparkSessionExtensions
             case Some(nativeOp) =>
               val cometOp = CometUnionExec(u, u.children)
               CometSinkPlaceHolder(nativeOp, u, cometOp)
+            case None =>
+              u
           }
 
         // Native shuffle for Comet operators

Original file line number	Diff line number	Diff line change
`@@ -327,6 +327,8 @@ class CometSparkSessionExtensions`
`327`	`327`	`case Some(nativeOp) =>`
`328`	`328`	`val cometOp = CometUnionExec(u, u.children)`
`329`	`329`	`CometSinkPlaceHolder(nativeOp, u, cometOp)`
	`330`	`+ case None =>`
	`331`	`+ u`
`330`	`332`	`}`
`331`	`333`
`332`	`334`	`// Native shuffle for Comet operators`