From e98ec7e447f1b6c05a2d194189878a8d51af173a Mon Sep 17 00:00:00 2001 From: nkeywal Date: Thu, 5 Jul 2012 10:10:01 +0000 Subject: [PATCH] HBASE-6328 FSHDFSUtils#recoverFileLease tries to rethrow InterruptedException but actually shallows it git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1357535 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/hadoop/hbase/util/FSHDFSUtils.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/FSHDFSUtils.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/FSHDFSUtils.java index 302a3b1b1e4..6ec8881fb06 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/FSHDFSUtils.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/FSHDFSUtils.java @@ -55,6 +55,7 @@ public class FSHDFSUtils extends FSUtils{ */ public static final long LEASE_SOFTLIMIT_PERIOD = 60 * 1000; + @Override public void recoverFileLease(final FileSystem fs, final Path p, Configuration conf) throws IOException{ if (!isAppendSupported(conf)) { @@ -111,7 +112,9 @@ public class FSHDFSUtils extends FSUtils{ try { Thread.sleep(1000); } catch (InterruptedException ex) { - new InterruptedIOException().initCause(ex); + InterruptedIOException iioe = new InterruptedIOException(); + iioe.initCause(ex); + throw iioe; } } LOG.info("Finished lease recover attempt for " + p);