chore: check missingInput for Comet plan nodes

comphead · comphead · commit 1b7079e4b003 · 2025-11-18T13:49:57.000-08:00
diff --git a/spark/src/test/scala/org/apache/spark/sql/CometTestBase.scala b/spark/src/test/scala/org/apache/spark/sql/CometTestBase.scala
@@ -419,7 +419,9 @@ abstract class CometTestBase
     val isCometNode = plan.nodeName.startsWith("Comet")
 
     if (isCometNode && hasMissingInput(plan)) {
-      assert(false, s"Plan node `${plan.nodeName}` has invalid missingInput: ${plan.missingInput}")
+      assert(
+        false,
+        s"Plan node `${plan.nodeName}` has invalid missingInput: ${plan.missingInput}")
     }
 
     // Otherwise recursively check children

Original file line number	Diff line number	Diff line change
`@@ -419,7 +419,9 @@ abstract class CometTestBase`
`419`	`419`	`val isCometNode = plan.nodeName.startsWith("Comet")`
`420`	`420`
`421`	`421`	`if (isCometNode && hasMissingInput(plan)) {`
`422`		- assert(false, s"Plan node `${plan.nodeName}` has invalid missingInput: ${plan.missingInput}")
	`422`	`+ assert(`
	`423`	`+ false,`
	`424`	+ s"Plan node `${plan.nodeName}` has invalid missingInput: ${plan.missingInput}")
`423`	`425`	`}`
`424`	`426`
`425`	`427`	`// Otherwise recursively check children`