diff --git a/spark/src/test/scala/org/apache/comet/CometCastSuite.scala b/spark/src/test/scala/org/apache/comet/CometCastSuite.scala index a56452e99..91da21bd6 100644 --- a/spark/src/test/scala/org/apache/comet/CometCastSuite.scala +++ b/spark/src/test/scala/org/apache/comet/CometCastSuite.scala @@ -897,6 +897,7 @@ class CometCastSuite extends CometTestBase with AdaptiveSparkPlanHelper { assert(cometMessage.contains(sparkInvalidValue)) } } + // try_cast() should always return null for invalid inputs val df2 = spark.sql(s"select a, try_cast(a as ${toType.sql}) from t order by a")