diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreFlusher.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreFlusher.java
index 149c0fe2b98..efd250bbfb2 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreFlusher.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreFlusher.java
@@ -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;
   }