From 32555beb83a43cf21d6a1703d667c8fab38137cd Mon Sep 17 00:00:00 2001 From: Matthew Date: Wed, 20 May 2015 17:54:57 -0400 Subject: [PATCH] Changed byteStream.getCount() to byteStream.getLength() so that RCFilePigStorage works with hive 0.14 'public int getCount()' was removed from org.apache.hadoop.hive.serde2.ByteStream.Output in hive 0.14 See: https://groups.google.com/forum/#!msg/elephantbird-dev/jNPK7p_QaNs/XshS_OLXNogJ https://issues.apache.org/jira/browse/PIG-3949 https://issues.apache.org/jira/browse/HIVE-6430 https://issues.apache.org/jira/secure/attachment/12642763/HIVE-6430.12.patch Hive 0.13: Hive 0.14: --- .../com/twitter/elephantbird/pig/store/RCFilePigStorage.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/rcfile/src/main/java/com/twitter/elephantbird/pig/store/RCFilePigStorage.java b/rcfile/src/main/java/com/twitter/elephantbird/pig/store/RCFilePigStorage.java index b201f75ba..5255540f7 100644 --- a/rcfile/src/main/java/com/twitter/elephantbird/pig/store/RCFilePigStorage.java +++ b/rcfile/src/main/java/com/twitter/elephantbird/pig/store/RCFilePigStorage.java @@ -207,8 +207,8 @@ public void putNext(Tuple t) throws IOException { StorageUtil.putField(byteStream, t.get(i)); colValRefs[i].set(byteStream.getData(), startPos, - byteStream.getCount() - startPos); - startPos = byteStream.getCount(); + byteStream.getLength() - startPos); + startPos = byteStream.getLength(); } try {