.../hbase/regionserver/DefaultStoreFlusher.java | 11 ++++++++++- .../regionserver/compactions/DefaultCompactor.java | 20 +++++++++++++++----- 2 files changed, 25 insertions(+), 6 deletions(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/DefaultStoreFlusher.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/DefaultStoreFlusher.java index bcf5e22..73b8cb9 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/DefaultStoreFlusher.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/DefaultStoreFlusher.java @@ -66,10 +66,19 @@ public class DefaultStoreFlusher extends StoreFlusher { writer = store.createWriterInTmp( cellsCount, store.getFamily().getCompression(), false, true, true); writer.setTimeRangeTracker(snapshot.getTimeRangeTracker()); + IOException e = null; try { performFlush(scanner, writer, smallestReadPoint); + } catch (IOException ioe) { + e = ioe; + // throw the exception out + throw ioe; } finally { - finalizeWriter(writer, cacheFlushId, status); + if (e != null) { + writer.close(); + } else { + finalizeWriter(writer, cacheFlushId, status); + } } } } finally { diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/DefaultCompactor.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/DefaultCompactor.java index 7139ea8..aae3968 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/DefaultCompactor.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/DefaultCompactor.java @@ -26,9 +26,9 @@ import java.util.List; import org.apache.hadoop.hbase.classification.InterfaceAudience; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.Path; -import org.apache.hadoop.hbase.regionserver.Store; import org.apache.hadoop.hbase.regionserver.InternalScanner; import org.apache.hadoop.hbase.regionserver.ScanType; +import org.apache.hadoop.hbase.regionserver.Store; import org.apache.hadoop.hbase.regionserver.StoreFile; import org.apache.hadoop.hbase.regionserver.StoreFileScanner; @@ -55,6 +55,7 @@ public class DefaultCompactor extends Compactor { StoreFile.Writer writer = null; List newFiles = new ArrayList(); boolean cleanSeqId = false; + IOException e = null; try { InternalScanner scanner = null; try { @@ -92,11 +93,20 @@ public class DefaultCompactor extends Compactor { scanner.close(); } } - } finally { + } catch (IOException ioe) { + e = ioe; + // Throw the exception + throw ioe; + } + finally { if (writer != null) { - writer.appendMetadata(fd.maxSeqId, request.isAllFiles()); - writer.close(); - newFiles.add(writer.getPath()); + if (e != null) { + writer.close(); + } else { + writer.appendMetadata(fd.maxSeqId, request.isAllFiles()); + writer.close(); + newFiles.add(writer.getPath()); + } } } return newFiles;