| commit | afa9c97140e14031b0117179ce28411888a8e238 | [log] [tgz] |
|---|---|---|
| author | Jianyong Dai <daijy@apache.org> | Thu Nov 10 23:14:52 2016 +0000 |
| committer | Jianyong Dai <daijy@apache.org> | Thu Nov 10 23:14:52 2016 +0000 |
| tree | db8ff43f55a93d2e0ef1fcde0c5761b18e5f7fbb | |
| parent | c6666c9df11aab3367e25cf3b93be4b3a939d64b [diff] |
PIG-5056: Fix AvroStorage writing enums git-svn-id: https://svn.apache.org/repos/asf/pig/trunk@1769229 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/CHANGES.txt b/CHANGES.txt index fe9bf12..8dd2a6f 100644 --- a/CHANGES.txt +++ b/CHANGES.txt
@@ -59,6 +59,8 @@ BUG FIXES +PIG-5056: Fix AvroStorage writing enums (szita via daijy) + PIG-5055: Infinite loop with join by fixed index (knoguchi) PIG-5049: Cleanup e2e tests turing_jython.conf (Daniel Dai)
diff --git a/src/org/apache/pig/impl/util/avro/AvroStorageDataConversionUtilities.java b/src/org/apache/pig/impl/util/avro/AvroStorageDataConversionUtilities.java index c9ccd09..acc8900 100644 --- a/src/org/apache/pig/impl/util/avro/AvroStorageDataConversionUtilities.java +++ b/src/org/apache/pig/impl/util/avro/AvroStorageDataConversionUtilities.java
@@ -118,6 +118,8 @@ return ByteBuffer.wrap(((DataByteArray) o).get()); case FIXED: return new GenericData.Fixed(s, ((DataByteArray) o).get()); + case ENUM: + return new GenericData.EnumSymbol(s,o.toString()); default: if (DataType.findType(o) == DataType.DATETIME) { return ((DateTime) o).getMillis();