Permalink
Browse files

add hopefully informative message about buffersize and LZO decompression

  • Loading branch information...
1 parent 1892f80 commit 5fcf69b567168e8d2a2803810c8eb5e57f628735 Eugene Joseph Koontz committed Feb 19, 2013
Showing with 10 additions and 0 deletions.
  1. +10 −0 src/java/com/hadoop/compression/lzo/LzoDecompressor.java
@@ -201,6 +201,16 @@ public LzoDecompressor() {
}
public synchronized void setInput(byte[] b, int off, int len) {
+ if (!isCurrentBlockUncompressed()) {
+ if (len > directBufferSize) {
+ LOG.warn("Decompression will fail because compressed buffer size :" +
+ len + " is greater than this decompressor's directBufferSize: " +
+ directBufferSize + ". To fix this, You can increase the value of your " +
+ "configuration's io.compression.codec.lzo.buffersize to be larger " +
+ "than: " + len + " and restart your job.");
+ }
+ }
+
if (b == null) {
throw new NullPointerException();
}

0 comments on commit 5fcf69b

Please sign in to comment.