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:47 UTC

svn commit: r1458450 - in /pig/trunk: CHANGES.txt contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/avro/AvroSchema2Pig.java

Author: cheolsoo
Date: Tue Mar 19 18:28:47 2013
New Revision: 1458450

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

Modified:
    pig/trunk/CHANGES.txt
    pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/avro/AvroSchema2Pig.java

Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1458450&r1=1458449&r2=1458450&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Tue Mar 19 18:28:47 2013
@@ -257,6 +257,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/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/avro/AvroSchema2Pig.java
URL: http://svn.apache.org/viewvc/pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/avro/AvroSchema2Pig.java?rev=1458450&r1=1458449&r2=1458450&view=diff
==============================================================================
--- pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/avro/AvroSchema2Pig.java (original)
+++ pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/avro/AvroSchema2Pig.java Tue Mar 19 18:28:47 2013
@@ -102,6 +102,7 @@ public class AvroSchema2Pig {
 
                 tupleSchema.setFields(childFields);
                 fieldSchema.setSchema(tupleSchema);
+                visitedRecords.remove(in);
             }
 
         } else if (avroType.equals(Schema.Type.ARRAY)) {