update

Author: wayneguow

connector/avro/src/main/scala/org/apache/spark/sql/avro/AvroDeserializer.scala

@@ -201,7 +201,7 @@ private[sql] class AvroDeserializer(
         updater.setFloat(ordinal, value.asInstanceOf[Float])
 
       case (FLOAT, DoubleType) => (updater, ordinal, value) =>
-        updater.setDouble(ordinal, value.asInstanceOf[Float].toString.toDouble)
+        updater.setDouble(ordinal, value.asInstanceOf[Float])
 
       case (DOUBLE, DoubleType) => (updater, ordinal, value) =>
         updater.setDouble(ordinal, value.asInstanceOf[Double])

connector/avro/src/test/scala/org/apache/spark/sql/avro/AvroSuite.scala

@@ -940,15 +940,15 @@ abstract class AvroSuite
 
       // Float -> Double
       val floatPath = s"$tempPath/float_data"
-      val floatDf = Seq(1.34F,
+      val floatDf = Seq(1F,
         Float.MinValue, Float.MinPositiveValue, Float.MaxValue,
         Float.NaN, Float.NegativeInfinity, Float.PositiveInfinity
       ).toDF("col")
       floatDf.write.format("avro").save(floatPath)
       checkAnswer(
         spark.read.schema("col Double").format("avro").load(floatPath),
-        Seq(Row(1.34D),
-          Row(-3.4028235E38D), Row(1.4E-45D), Row(3.4028235E38D),
+        Seq(Row(1D),
+          Row(-3.4028234663852886E38D), Row(1.401298464324817E-45D), Row(3.4028234663852886E38D),
           Row(Double.NaN), Row(Double.NegativeInfinity), Row(Double.PositiveInfinity))
       )
     }