Github user gengliangwang commented on a diff in the pull request:
https://github.com/apache/spark/pull/22094#discussion_r209810245
--- Diff:
external/avro/src/test/scala/org/apache/spark/sql/avro/AvroSuite.scala ---
@@ -850,6 +851,62 @@ class AvroSuite extends QueryTest with
SharedSQLContext with SQLTestUtils {
}
}
+ test("throw exception if unable to write with user provided Avro
schema") {
+ val input: Seq[(DataType, Schema.Type)] = Seq(
+ (NullType, NULL),
+ (BooleanType, BOOLEAN),
+ (ByteType, INT),
+ (IntegerType, INT),
+ (LongType, LONG),
+ (FloatType, FLOAT),
+ (DoubleType, DOUBLE),
+ (BinaryType, BYTES),
+ (DateType, INT),
+ (TimestampType, LONG)
--- End diff --
@dongjoon-hyun Thanks, I have updated the test.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
