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:10:01 UTC
svn commit: r1357535 -
/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/util/FSHDFSUtils.java
Author: nkeywal
Date: Thu Jul 5 10:10:01 2012
New Revision: 1357535
URL: http://svn.apache.org/viewvc?rev=1357535&view=rev
Log:
HBASE-6328 FSHDFSUtils#recoverFileLease tries to rethrow InterruptedException but actually shallows it
Modified:
hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/util/FSHDFSUtils.java
Modified: hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/util/FSHDFSUtils.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/util/FSHDFSUtils.java?rev=1357535&r1=1357534&r2=1357535&view=diff
==============================================================================
--- hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/util/FSHDFSUtils.java (original)
+++ hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/util/FSHDFSUtils.java Thu Jul 5 10:10:01 2012
@@ -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);