You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by ch...@apache.org on 2013/03/19 19:28:24 UTC

svn commit: r1458448 - in /pig/branches/branch-0.11: CHANGES.txt contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/avro/AvroSchema2Pig.java

Author: cheolsoo
Date: Tue Mar 19 18:28:24 2013
New Revision: 1458448

URL: http://svn.apache.org/r1458448
Log:
PIG-3252: AvroStorage gives wrong schema for schemas with named records (mwagner via cheolsoo)

Modified:
    pig/branches/branch-0.11/CHANGES.txt
    pig/branches/branch-0.11/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/avro/AvroSchema2Pig.java

Modified: pig/branches/branch-0.11/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.11/CHANGES.txt?rev=1458448&r1=1458447&r2=1458448&view=diff
==============================================================================
--- pig/branches/branch-0.11/CHANGES.txt (original)
+++ pig/branches/branch-0.11/CHANGES.txt Tue Mar 19 18:28:24 2013
@@ -36,6 +36,8 @@ OPTIMIZATIONS
 
 BUG FIXES
 
+PIG-3252: AvroStorage gives wrong schema for schemas with named records (mwagner via cheolsoo)
+
 PIG-3132: NPE when illustrating a relation with HCatLoader (daijy)
 
 PIG-3194: Changes to ObjectSerializer.java break compatibility with Hadoop 0.20.2 (prkommireddi via dvryaboy)

Modified: pig/branches/branch-0.11/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/avro/AvroSchema2Pig.java
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.11/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/avro/AvroSchema2Pig.java?rev=1458448&r1=1458447&r2=1458448&view=diff
==============================================================================
--- pig/branches/branch-0.11/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/avro/AvroSchema2Pig.java (original)
+++ pig/branches/branch-0.11/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/avro/AvroSchema2Pig.java Tue Mar 19 18:28:24 2013
@@ -102,6 +102,7 @@ public class AvroSchema2Pig {
 
                 tupleSchema.setFields(childFields);
                 fieldSchema.setSchema(tupleSchema);
+                visitedRecords.remove(in);
             }
 
         } else if (avroType.equals(Schema.Type.ARRAY)) {