|
@@ -943,15 +943,15 @@ public class SequenceFile {
|
|
|
|
|
|
/** Close the file. */
|
|
/** Close the file. */
|
|
public synchronized void close() throws IOException {
|
|
public synchronized void close() throws IOException {
|
|
- CodecPool.returnCompressor(compressor);
|
|
|
|
- compressor = null;
|
|
|
|
-
|
|
|
|
keySerializer.close();
|
|
keySerializer.close();
|
|
uncompressedValSerializer.close();
|
|
uncompressedValSerializer.close();
|
|
if (compressedValSerializer != null) {
|
|
if (compressedValSerializer != null) {
|
|
compressedValSerializer.close();
|
|
compressedValSerializer.close();
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ CodecPool.returnCompressor(compressor);
|
|
|
|
+ compressor = null;
|
|
|
|
+
|
|
if (out != null) {
|
|
if (out != null) {
|
|
|
|
|
|
// Close the underlying stream iff we own it...
|
|
// Close the underlying stream iff we own it...
|