You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by nk...@apache.org on 2012/07/05 12:33:47 UTC
svn commit: r1357539 -
/hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/util/FSHDFSUtils.java
Author: nkeywal
Date: Thu Jul 5 10:33:47 2012
New Revision: 1357539
URL: http://svn.apache.org/viewvc?rev=1357539&view=rev
Log:
HBASE-6328 FSHDFSUtils#recoverFileLease tries to rethrow InterruptedException but actually shallows it
Modified:
hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/util/FSHDFSUtils.java
Modified: hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/util/FSHDFSUtils.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/util/FSHDFSUtils.java?rev=1357539&r1=1357538&r2=1357539&view=diff
==============================================================================
--- hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/util/FSHDFSUtils.java (original)
+++ hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/util/FSHDFSUtils.java Thu Jul 5 10:33:47 2012
@@ -51,6 +51,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);