hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ecl...@apache.org
Subject svn commit: r1549927 - /hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreFlusher.java
Date Tue, 10 Dec 2013 18:41:32 GMT
Author: eclark
Date: Tue Dec 10 18:41:32 2013
New Revision: 1549927

URL: http://svn.apache.org/r1549927
Log:
HBASE-10110 Fix Potential Resource Leak in StoreFlusher

Modified:
    hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreFlusher.java

Modified: hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreFlusher.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreFlusher.java?rev=1549927&r1=1549926&r2=1549927&view=diff
==============================================================================
--- hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreFlusher.java
(original)
+++ hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreFlusher.java
Tue Dec 10 18:41:32 2013
@@ -100,7 +100,12 @@ abstract class StoreFlusher {
     }
     assert scanner != null;
     if (store.getCoprocessorHost() != null) {
-      return store.getCoprocessorHost().preFlush(store, scanner);
+      try {
+        return store.getCoprocessorHost().preFlush(store, scanner);
+      } catch (IOException ioe) {
+        scanner.close();
+        throw ioe;
+      }
     }
     return scanner;
   }



Mime
View raw message