Skip to content

Decompressor's finished() fix #2

Open
wants to merge 1 commit into from
View
2 src/org/anarres/lzo/hadoop/codec/LzoDecompressor.java
@@ -205,6 +205,8 @@ public boolean needsDictionary() {
@Override
public boolean finished() {
// logState("Before finished");
+ if (outputBufferLen.value == 0 && outputBufferPos == 0)
+ return false;
return outputBufferLen.value <= 0;
// return false;
}
Something went wrong with that request. Please try again.