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 =