flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rmetz...@apache.org
Subject flink git commit: [hotfix] Fix issue with nested Avro types
Date Tue, 03 Mar 2015 14:48:21 GMT
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 <rmetzger@apache.org>
Authored: Tue Mar 3 14:34:11 2015 +0100
Committer: Robert Metzger <rmetzger@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


Mime
View raw message