You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by zs...@apache.org on 2009/03/12 06:30:55 UTC

svn commit: r752776 - in /hadoop/core/branches/branch-0.20: CHANGES.txt src/core/org/apache/hadoop/io/compress/bzip2/CBZip2InputStream.java

Author: zshao
Date: Thu Mar 12 05:30:55 2009
New Revision: 752776

URL: http://svn.apache.org/viewvc?rev=752776&view=rev
Log:
HADOOP-5379. CBZip2InputStream to throw IOException on data crc error. (Rodrigo Schmidt via zshao)

Modified:
    hadoop/core/branches/branch-0.20/CHANGES.txt
    hadoop/core/branches/branch-0.20/src/core/org/apache/hadoop/io/compress/bzip2/CBZip2InputStream.java

Modified: hadoop/core/branches/branch-0.20/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/core/branches/branch-0.20/CHANGES.txt?rev=752776&r1=752775&r2=752776&view=diff
==============================================================================
--- hadoop/core/branches/branch-0.20/CHANGES.txt (original)
+++ hadoop/core/branches/branch-0.20/CHANGES.txt Thu Mar 12 05:30:55 2009
@@ -347,6 +347,9 @@
 
   BUG FIXES
 
+    HADOOP-5379. CBZip2InputStream to throw IOException on data crc error.
+    (Rodrigo Schmidt via zshao)
+
     HADOOP-5326. Fixes CBZip2OutputStream data corruption problem.
     (Rodrigo Schmidt via zshao)
 

Modified: hadoop/core/branches/branch-0.20/src/core/org/apache/hadoop/io/compress/bzip2/CBZip2InputStream.java
URL: http://svn.apache.org/viewvc/hadoop/core/branches/branch-0.20/src/core/org/apache/hadoop/io/compress/bzip2/CBZip2InputStream.java?rev=752776&r1=752775&r2=752776&view=diff
==============================================================================
--- hadoop/core/branches/branch-0.20/src/core/org/apache/hadoop/io/compress/bzip2/CBZip2InputStream.java (original)
+++ hadoop/core/branches/branch-0.20/src/core/org/apache/hadoop/io/compress/bzip2/CBZip2InputStream.java Thu Mar 12 05:30:55 2009
@@ -51,11 +51,9 @@
 public class CBZip2InputStream extends InputStream implements BZip2Constants {
 
   private static void reportCRCError() throws IOException {
-    // The clean way would be to throw an exception.
-    // throw new IOException("crc error");
 
-    // Just print a message, like the previous versions of this class did
-    System.err.println("BZip2 CRC error");
+  	throw new IOException("BZip2 CRC error");
+
   }
 
   private void makeMaps() {