You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by rm...@apache.org on 2015/03/03 15:48:21 UTC
flink git commit: [hotfix] Fix issue with nested Avro types
Repository: flink
Updated Branches:
refs/heads/master 6b79aca67 -> dec5e333d
[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/dec5e333
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/dec5e333
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/dec5e333
Branch: refs/heads/master
Commit: dec5e333dfd7b5e4397a14f7a384a93508035638
Parents: 6b79aca
Author: Robert Metzger <rm...@apache.org>
Authored: Tue Mar 3 14:34:11 2015 +0100
Committer: Robert Metzger <rm...@apache.org>
Committed: Tue Mar 3 15:47:52 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/dec5e333/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 bf580d1..ed03627 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
@@ -54,7 +54,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