Github user dongjoon-hyun commented on a diff in the pull request:
https://github.com/apache/spark/pull/22094#discussion_r209779455
--- 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),
--- End diff --
Could you add `(ShortType, INT),`, too?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
