[FLINK-10605] [avro] Upgrade AvroSerializer and snapshot for Avro sch…

…ema evolution This closes apache#6881.
denggeng · Oct 30, 2018 · b0b10ed · b0b10ed
1 parent 70f4141
commit b0b10ed
Show file tree

Hide file tree

Showing 12 changed files with 799 additions and 1,007 deletions.
diff --git a/flink-formats/flink-avro/src/main/java/org/apache/flink/api/java/typeutils/AvroTypeInfo.java b/flink-formats/flink-avro/src/main/java/org/apache/flink/api/java/typeutils/AvroTypeInfo.java
diff --git a/.../flink-avro/src/main/java/org/apache/flink/api/java/typeutils/runtime/AvroSerializer.java b/.../flink-avro/src/main/java/org/apache/flink/api/java/typeutils/runtime/AvroSerializer.java
diff --git a/...ats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java b/...ats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java
@@ -164,7 +164,7 @@ public boolean isEndOfStream(T nextElement) {
 	@SuppressWarnings("unchecked")
 	public TypeInformation<T> getProducedType() {
 		if (SpecificRecord.class.isAssignableFrom(recordClazz)) {
-			return new AvroTypeInfo(recordClazz, false);
+			return new AvroTypeInfo(recordClazz);
 		} else {
 			return (TypeInformation<T>) new GenericRecordAvroTypeInfo(this.reader);
 		}