You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by da...@apache.org on 2014/05/26 04:26:41 UTC

svn commit: r1597500 - in /pig/branches/branch-0.13: CHANGES.txt contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/HiveColumnarStorage.java

Author: daijy
Date: Mon May 26 02:26:40 2014
New Revision: 1597500

URL: http://svn.apache.org/r1597500
Log:
PIG-3949: HiveColumnarStorage compile failure with Hive 0.14.0

Modified:
    pig/branches/branch-0.13/CHANGES.txt
    pig/branches/branch-0.13/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/HiveColumnarStorage.java

Modified: pig/branches/branch-0.13/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.13/CHANGES.txt?rev=1597500&r1=1597499&r2=1597500&view=diff
==============================================================================
--- pig/branches/branch-0.13/CHANGES.txt (original)
+++ pig/branches/branch-0.13/CHANGES.txt Mon May 26 02:26:40 2014
@@ -141,6 +141,8 @@ PIG-3882: Multiquery off mode execution 
  
 BUG FIXES
 
+PIG-3949: HiveColumnarStorage compile failure with Hive 0.14.0 (daijy)
+
 PIG-3960: Compile fail against Hadoop 2.4.0 after PIG-3913 (daijy)
 
 PIG-3950: Removing empty file PColFilterExtractor.java speeds up rebuilds (mrflip via cheolsoo)

Modified: pig/branches/branch-0.13/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/HiveColumnarStorage.java
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.13/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/HiveColumnarStorage.java?rev=1597500&r1=1597499&r2=1597500&view=diff
==============================================================================
--- pig/branches/branch-0.13/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/HiveColumnarStorage.java (original)
+++ pig/branches/branch-0.13/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/HiveColumnarStorage.java Mon May 26 02:26:40 2014
@@ -103,8 +103,8 @@ public class HiveColumnarStorage extends
         for (int i = 0; i < sz && i < numColumns; i++) {
 
             putField(byteStream, t.get(i));
-            colValRefs[i].set(byteStream.getData(), startPos, byteStream.getCount() - startPos);
-            startPos = byteStream.getCount();
+            colValRefs[i].set(byteStream.getData(), startPos, byteStream.getLength() - startPos);
+            startPos = byteStream.getLength();
         }
 
         try {