This is an automated email from the ASF dual-hosted git repository. changchen pushed a commit to branch feature/ansi-ci-baseline in repository https://gitbox.apache.org/repos/asf/gluten.git
commit c9ec47c932dbce92d4800b47b806ca3f17fefb96 Author: Chang chen <[email protected]> AuthorDate: Fri Apr 10 17:11:45 2026 +0000 [GLUTEN-10134][VL] Restore UDT registration in GlutenCastWithAnsiOffSuite for SPARK-32828 Gluten's checkEvaluation uses DataFrame collect() via RowEncoder, which requires UDT registration to serialize UserDefinedType values. The registration was accidentally removed during suite simplification. Co-Authored-By: Claude Opus 4 <[email protected]> --- .../spark/sql/catalyst/expressions/GlutenCastWithAnsiOffSuite.scala | 5 +++++ .../spark/sql/catalyst/expressions/GlutenCastWithAnsiOffSuite.scala | 5 +++++ 2 files changed, 10 insertions(+) diff --git a/gluten-ut/spark40/src/test/scala/org/apache/spark/sql/catalyst/expressions/GlutenCastWithAnsiOffSuite.scala b/gluten-ut/spark40/src/test/scala/org/apache/spark/sql/catalyst/expressions/GlutenCastWithAnsiOffSuite.scala index 9687a92040..091596d58e 100644 --- a/gluten-ut/spark40/src/test/scala/org/apache/spark/sql/catalyst/expressions/GlutenCastWithAnsiOffSuite.scala +++ b/gluten-ut/spark40/src/test/scala/org/apache/spark/sql/catalyst/expressions/GlutenCastWithAnsiOffSuite.scala @@ -27,6 +27,11 @@ import java.sql.{Date, Timestamp} import java.util.{Calendar, TimeZone} class GlutenCastWithAnsiOffSuite extends CastWithAnsiOffSuite with GlutenTestsTrait { + // Register UDT for test("SPARK-32828"). Gluten's checkEvaluation collects via RowEncoder, + // which needs UDT registration to serialize UserDefinedType values. + UDTRegistration.register(classOf[IExampleBaseType].getName, classOf[ExampleBaseTypeUDT].getName) + UDTRegistration.register(classOf[IExampleSubType].getName, classOf[ExampleSubTypeUDT].getName) + override def beforeAll(): Unit = { super.beforeAll() // Need to explicitly set spark.sql.preserveCharVarcharTypeInfo=true for gluten's test diff --git a/gluten-ut/spark41/src/test/scala/org/apache/spark/sql/catalyst/expressions/GlutenCastWithAnsiOffSuite.scala b/gluten-ut/spark41/src/test/scala/org/apache/spark/sql/catalyst/expressions/GlutenCastWithAnsiOffSuite.scala index 0efb5d5f81..ffb05b972b 100644 --- a/gluten-ut/spark41/src/test/scala/org/apache/spark/sql/catalyst/expressions/GlutenCastWithAnsiOffSuite.scala +++ b/gluten-ut/spark41/src/test/scala/org/apache/spark/sql/catalyst/expressions/GlutenCastWithAnsiOffSuite.scala @@ -27,6 +27,11 @@ import java.sql.{Date, Timestamp} import java.util.{Calendar, TimeZone} class GlutenCastWithAnsiOffSuite extends CastWithAnsiOffSuite with GlutenTestsTrait { + // Register UDT for test("SPARK-32828"). Gluten's checkEvaluation collects via RowEncoder, + // which needs UDT registration to serialize UserDefinedType values. + UDTRegistration.register(classOf[IExampleBaseType].getName, classOf[ExampleBaseTypeUDT].getName) + UDTRegistration.register(classOf[IExampleSubType].getName, classOf[ExampleSubTypeUDT].getName) + override def beforeAll(): Unit = { super.beforeAll() conf.setConf(SQLConf.PRESERVE_CHAR_VARCHAR_TYPE_INFO, true) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
