Author: omalley
Date: Tue Oct 2 11:36:41 2007
New Revision: 581342
URL: http://svn.apache.org/viewvc?rev=581342&view=rev
Log:
HADOOP-1972. Fix LzoCompressor to ensure the user has actually asked
to finish compression. (arun via omalley)
Modified:
lucene/hadoop/trunk/CHANGES.txt
lucene/hadoop/trunk/src/java/org/apache/hadoop/io/compress/lzo/LzoCompressor.java
Modified: lucene/hadoop/trunk/CHANGES.txt
URL:
http://svn.apache.org/viewvc/lucene/hadoop/trunk/CHANGES.txt?rev=581342&r1=581341&r2=581342&view=diff
==============================================================================
--- lucene/hadoop/trunk/CHANGES.txt (original)
+++ lucene/hadoop/trunk/CHANGES.txt Tue Oct 2 11:36:41 2007
@@ -334,6 +334,9 @@
HADOOP-1977. Fixed handling of ToolBase cli options in JobClient.
(enis via omalley)
+ HADOOP-1972. Fix LzoCompressor to ensure the user has actually asked
+ to finish compression. (arun via omalley)
+
Release 0.14.1 - 2007-09-04
BUG FIXES
Modified:
lucene/hadoop/trunk/src/java/org/apache/hadoop/io/compress/lzo/LzoCompressor.java
URL:
http://svn.apache.org/viewvc/lucene/hadoop/trunk/src/java/org/apache/hadoop/io/compress/lzo/LzoCompressor.java?rev=581342&r1=581341&r2=581342&view=diff
==============================================================================
---
lucene/hadoop/trunk/src/java/org/apache/hadoop/io/compress/lzo/LzoCompressor.java
(original)
+++
lucene/hadoop/trunk/src/java/org/apache/hadoop/io/compress/lzo/LzoCompressor.java
Tue Oct 2 11:36:41 2007
@@ -256,7 +256,7 @@
public synchronized boolean finished() {
// Check if 'lzo' says its 'finished' and
// all compressed data has been consumed
- return (finished && compressedDirectBuf.remaining() == 0);
+ return (finish && finished && compressedDirectBuf.remaining() == 0);
}
public synchronized int compress(byte[] b, int off, int len)
