hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From te...@apache.org
Subject hbase git commit: HBASE-12614 Potentially unclosed StoreFile(s) in DefaultCompactor#compact()
Date Wed, 03 Dec 2014 03:35:42 GMT
Repository: hbase
Updated Branches:
  refs/heads/0.98 6325e0296 -> ee97c9259


HBASE-12614 Potentially unclosed StoreFile(s) in DefaultCompactor#compact()


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/ee97c925
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/ee97c925
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/ee97c925

Branch: refs/heads/0.98
Commit: ee97c9259eab2da350dca6525800fe1f89d5aa50
Parents: 6325e02
Author: tedyu <yuzhihong@gmail.com>
Authored: Tue Dec 2 19:35:32 2014 -0800
Committer: tedyu <yuzhihong@gmail.com>
Committed: Tue Dec 2 19:35:32 2014 -0800

----------------------------------------------------------------------
 .../hbase/regionserver/compactions/DefaultCompactor.java  | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/ee97c925/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/DefaultCompactor.java
----------------------------------------------------------------------
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 e0a4ea1..1c23b65 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
@@ -24,6 +24,8 @@ import java.util.Collection;
 import java.util.Collections;
 import java.util.List;
 
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.hbase.classification.InterfaceAudience;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.Path;
@@ -38,6 +40,8 @@ import org.apache.hadoop.hbase.regionserver.StoreFileScanner;
  */
 @InterfaceAudience.Private
 public class DefaultCompactor extends Compactor {
+  private static final Log LOG = LogFactory.getLog(DefaultCompactor.class);
+
   public DefaultCompactor(final Configuration conf, final Store store) {
     super(conf, store);
   }
@@ -120,7 +124,11 @@ public class DefaultCompactor extends Compactor {
         }
       } finally {
         for (StoreFile f : readersToClose) {
-          f.closeReader(true);
+          try {
+            f.closeReader(true);
+          } catch (IOException ioe) {
+            LOG.warn("Exception closing " + f, ioe);
+          }
         }
       }
     }


Mime
View raw message