nit

turboFei · turboFei · commit 99a3485c8b39 · 2025-11-03T19:11:32.000-08:00
diff --git a/amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/main/scala/org/apache/amoro/spark/SparkInternalRowCastWrapper.scala b/amoro-format-mixed/amoro-mixed-spark/v3.3/amoro-mixed-spark-3.3/src/main/scala/org/apache/amoro/spark/SparkInternalRowCastWrapper.scala
@@ -40,7 +40,7 @@ class SparkInternalRowCastWrapper(
   def getSchema: StructType = schema
 
   override protected def genericGet(ordinal: Int): Any = {
-    row.get(ordinal, schema.apply(ordinal).dataType)
+    row.get(ordinal, dataTypeList(ordinal))
   }
 
   override def toSeq(fieldTypes: Seq[DataType]): Seq[Any] = {
diff --git a/amoro-format-mixed/amoro-mixed-spark/v3.5/amoro-mixed-spark-3.5/src/main/scala/org/apache/amoro/spark/SparkInternalRowCastWrapper.scala b/amoro-format-mixed/amoro-mixed-spark/v3.5/amoro-mixed-spark-3.5/src/main/scala/org/apache/amoro/spark/SparkInternalRowCastWrapper.scala
@@ -40,7 +40,7 @@ class SparkInternalRowCastWrapper(
   def getSchema: StructType = schema
 
   override protected def genericGet(ordinal: Int): Any = {
-    row.get(ordinal, schema.apply(ordinal).dataType)
+    row.get(ordinal, dataTypeList(ordinal))
   }
 
   override def toSeq(fieldTypes: Seq[DataType]): Seq[Any] = {

Original file line number	Diff line number	Diff line change
`@@ -40,7 +40,7 @@ class SparkInternalRowCastWrapper(`
`40`	`40`	`def getSchema: StructType = schema`
`41`	`41`
`42`	`42`	`override protected def genericGet(ordinal: Int): Any = {`
`43`		`- row.get(ordinal, schema.apply(ordinal).dataType)`
	`43`	`+ row.get(ordinal, dataTypeList(ordinal))`
`44`	`44`	`}`
`45`	`45`
`46`	`46`	`override def toSeq(fieldTypes: Seq[DataType]): Seq[Any] = {`