Repository: flink Updated Branches: refs/heads/release-0.8 095301e02 -> 2f94d4257
[hotfix] Fix issue with nested Avro types Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2f94d425 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2f94d425 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2f94d425 Branch: refs/heads/release-0.8 Commit: 2f94d4257c485e566b31cb7062d31832da91782b Parents: 095301e Author: Robert Metzger <rmetz...@apache.org> Authored: Sun Mar 15 17:06:07 2015 +0100 Committer: Robert Metzger <rmetz...@apache.org> Committed: Sun Mar 15 17:06:07 2015 +0100 ---------------------------------------------------------------------- .../java/org/apache/flink/api/java/typeutils/AvroTypeInfo.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/2f94d425/flink-java/src/main/java/org/apache/flink/api/java/typeutils/AvroTypeInfo.java ---------------------------------------------------------------------- diff --git a/flink-java/src/main/java/org/apache/flink/api/java/typeutils/AvroTypeInfo.java b/flink-java/src/main/java/org/apache/flink/api/java/typeutils/AvroTypeInfo.java index ccdf7f7..d05ace1 100644 --- a/flink-java/src/main/java/org/apache/flink/api/java/typeutils/AvroTypeInfo.java +++ b/flink-java/src/main/java/org/apache/flink/api/java/typeutils/AvroTypeInfo.java @@ -48,7 +48,7 @@ public class AvroTypeInfo<T extends SpecificRecordBase> extends PojoTypeInfo<T> PojoTypeInfo pti = (PojoTypeInfo) ti; List<PojoField> newFields = new ArrayList<PojoField>(pti.getTotalFields()); - for(int i = 0; i < pti.getTotalFields(); i++) { + for(int i = 0; i < pti.getArity(); i++) { PojoField f = pti.getPojoFieldAt(i); TypeInformation newType = f.type; // check if type is a CharSequence
