diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java index bea8f45..5b7d41d 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java @@ -4841,8 +4841,12 @@ public class HRegion implements HeapSize { // , Writable{ WALEdit walEdit = new WALEdit(); // 1. Run pre-process hook - processor.preProcess(this, walEdit); - + try { + processor.preProcess(this, walEdit); + } catch (IOException e) { + closeRegionOperation(); + throw e; + } // Short circuit the read only case if (processor.readOnly()) { try {