Repository: hbase Updated Branches: refs/heads/0.94 403d4eb4d -> d12bf9654
HBASE-5835: Catch and handle NotServingRegionException when close region attempt fails Signed-off-by: stack <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/d12bf965 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/d12bf965 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/d12bf965 Branch: refs/heads/0.94 Commit: d12bf9654184f3dd1e2ba86ff89bb758b1138f77 Parents: 403d4eb Author: Esteban Gutierrez <[email protected]> Authored: Tue Dec 30 23:26:05 2014 -0800 Committer: stack <[email protected]> Committed: Wed Dec 31 09:57:05 2014 -0800 ---------------------------------------------------------------------- .../java/org/apache/hadoop/hbase/util/HBaseFsckRepair.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/d12bf965/src/main/java/org/apache/hadoop/hbase/util/HBaseFsckRepair.java ---------------------------------------------------------------------- diff --git a/src/main/java/org/apache/hadoop/hbase/util/HBaseFsckRepair.java b/src/main/java/org/apache/hadoop/hbase/util/HBaseFsckRepair.java index 81ad866..03f8a1c 100644 --- a/src/main/java/org/apache/hadoop/hbase/util/HBaseFsckRepair.java +++ b/src/main/java/org/apache/hadoop/hbase/util/HBaseFsckRepair.java @@ -147,7 +147,11 @@ public class HBaseFsckRepair { HConnection connection = admin.getConnection(); HRegionInterface rs = connection.getHRegionConnection(server.getHostname(), server.getPort()); - rs.closeRegion(region, false); + try { + rs.closeRegion(region, false); + } catch (IOException ioe) { + LOG.warn("Exception when closing region: " + region.getRegionNameAsString(), ioe); + } long timeout = admin.getConfiguration() .getLong("hbase.hbck.close.timeout", 120000); long expiration = timeout + System.currentTimeMillis();
