Update spark/src/test/scala/org/apache/spark/sql/CometTestBase.scala

comphead · martin-g · web-flow · commit 11e9ffecf6cb · 2025-11-18T11:49:20.000-08:00
Co-authored-by: Martin Grigorov &lt;martin-g@users.noreply.github.com&gt;
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,7 @@ abstract class CometTestBase
     val isCometNode = plan.nodeName.startsWith("Comet")
 
     if (isCometNode && hasMissingInput(plan)) {
-      assert(false, s"Plan node `${plan.nodeName}` has invalid 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,7 @@ 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")
	`422`	+ assert(false, s"Plan node `${plan.nodeName}` has invalid missingInput: ${plan.missingInput}")
`423`	`423`	`}`
`424`	`424`
`425`	`425`	`// Otherwise recursively check children`