pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zjf...@apache.org
Subject svn commit: r957406 - in /hadoop/pig/trunk: CHANGES.txt src/org/apache/pig/builtin/PigStorage.java
Date Thu, 24 Jun 2010 03:36:11 GMT
Author: zjffdu
Date: Thu Jun 24 03:36:10 2010
New Revision: 957406

URL: http://svn.apache.org/viewvc?rev=957406&view=rev
Log:
PIG-1463: Replace "bz" with ".bz" in setStoreLocation in PigStorage 

Modified:
    hadoop/pig/trunk/CHANGES.txt
    hadoop/pig/trunk/src/org/apache/pig/builtin/PigStorage.java

Modified: hadoop/pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/pig/trunk/CHANGES.txt?rev=957406&r1=957405&r2=957406&view=diff
==============================================================================
--- hadoop/pig/trunk/CHANGES.txt (original)
+++ hadoop/pig/trunk/CHANGES.txt Thu Jun 24 03:36:10 2010
@@ -93,6 +93,8 @@ PIG-1309: Map-side Cogroup (ashutoshc)
 
 BUG FIXES
 
+PIG-1463: Replace "bz" with ".bz" in setStoreLocation in PigStorage (zjffdu)
+
 PIG-1221: Filter equality does not work for tuples (zjffdu)
 
 PIG-1456: TestMultiQuery takes a long time to run (rding)

Modified: hadoop/pig/trunk/src/org/apache/pig/builtin/PigStorage.java
URL: http://svn.apache.org/viewvc/hadoop/pig/trunk/src/org/apache/pig/builtin/PigStorage.java?rev=957406&r1=957405&r2=957406&view=diff
==============================================================================
--- hadoop/pig/trunk/src/org/apache/pig/builtin/PigStorage.java (original)
+++ hadoop/pig/trunk/src/org/apache/pig/builtin/PigStorage.java Thu Jun 24 03:36:10 2010
@@ -231,7 +231,7 @@ LoadPushDown {
     public void setStoreLocation(String location, Job job) throws IOException {
         job.getConfiguration().set("mapred.textoutputformat.separator", "");
         FileOutputFormat.setOutputPath(job, new Path(location));
-        if (location.endsWith(".bz2") || location.endsWith("bz")) {
+        if (location.endsWith(".bz2") || location.endsWith(".bz")) {
             FileOutputFormat.setCompressOutput(job, true);
             FileOutputFormat.setOutputCompressorClass(job,  BZip2Codec.class);
         }  else if (location.endsWith(".gz")) {



Mime
View raw message