Update AdaptiveQueryExecSuite.scala

pjfanning · pjfanning · commit 45265f2da0b6 · 2025-06-05T13:25:19.000+01:00
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/execution/adaptive/AdaptiveQueryExecSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/execution/adaptive/AdaptiveQueryExecSuite.scala
@@ -936,7 +936,7 @@ class AdaptiveQueryExecSuite
             joined.collect()
           }
           val exceptionMessages = (Seq(error) ++ Option(error.getCause) ++ error.getSuppressed())
-            .flatMap(e => Some(e.getMessage))
+            .flatMap(e => Option(e.getMessage))
           assert(exceptionMessages.exists(_.contains("coalesce test error")))
 
           val adaptivePlan = joined.queryExecution.executedPlan.asInstanceOf[AdaptiveSparkPlanExec]

Original file line number	Diff line number	Diff line change
`@@ -936,7 +936,7 @@ class AdaptiveQueryExecSuite`
`936`	`936`	`joined.collect()`
`937`	`937`	`}`
`938`	`938`	`val exceptionMessages = (Seq(error) ++ Option(error.getCause) ++ error.getSuppressed())`
`939`		`- .flatMap(e => Some(e.getMessage))`
	`939`	`+ .flatMap(e => Option(e.getMessage))`
`940`	`940`	`assert(exceptionMessages.exists(_.contains("coalesce test error")))`
`941`	`941`
`942`	`942`	`val adaptivePlan = joined.queryExecution.executedPlan.asInstanceOf[AdaptiveSparkPlanExec]`