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 2013/03/20 00:34:11 UTC

svn commit: r1458569 - in /pig/trunk: CHANGES.txt contrib/zebra/src/java/org/apache/hadoop/zebra/tfile/Compression.java

Author: daijy
Date: Tue Mar 19 23:34:11 2013
New Revision: 1458569

URL: http://svn.apache.org/r1458569
Log:
PIG-3208: [zebra] TFile should not set io.compression.codec.lzo.buffersize

Modified:
    pig/trunk/CHANGES.txt
    pig/trunk/contrib/zebra/src/java/org/apache/hadoop/zebra/tfile/Compression.java

Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1458569&r1=1458568&r2=1458569&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Tue Mar 19 23:34:11 2013
@@ -149,6 +149,8 @@ PIG-3013: BinInterSedes improve chararra
 
 BUG FIXES
 
+PIG-3208: [zebra] TFile should not set io.compression.codec.lzo.buffersize (ekoontz via daijy)
+
 PIG-3172: Partition filter push down does not happen when there is a non partition key map column filter (rohini)
 
 PIG-3205: Passing arguments to python script does not work with -f option (rohini)

Modified: pig/trunk/contrib/zebra/src/java/org/apache/hadoop/zebra/tfile/Compression.java
URL: http://svn.apache.org/viewvc/pig/trunk/contrib/zebra/src/java/org/apache/hadoop/zebra/tfile/Compression.java?rev=1458569&r1=1458568&r2=1458569&view=diff
==============================================================================
--- pig/trunk/contrib/zebra/src/java/org/apache/hadoop/zebra/tfile/Compression.java (original)
+++ pig/trunk/contrib/zebra/src/java/org/apache/hadoop/zebra/tfile/Compression.java Tue Mar 19 23:34:11 2013
@@ -124,7 +124,6 @@ final class Compression {
         } else {
           bis1 = downStream;
         }
-        conf.setInt("io.compression.codec.lzo.buffersize", 64 * 1024);
         CompressionInputStream cis =
             codec.createInputStream(bis1, decompressor);
         BufferedInputStream bis2 = new BufferedInputStream(cis, DATA_IBUF_SIZE);
@@ -146,7 +145,6 @@ final class Compression {
         } else {
           bos1 = downStream;
         }
-        conf.setInt("io.compression.codec.lzo.buffersize", 64 * 1024);
         CompressionOutputStream cos =
             codec.createOutputStream(bos1, compressor);
         BufferedOutputStream bos2 =