Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-18312 Ineffective handling of FileNotFoundException in FileLink.tryOpen()

This commit is contained in:
tedyu 2017-07-05 21:02:28 -07:00
parent 3a0a3fd5fe
commit 5d710bbe7f
2 changed files with 35 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hbase-server/src/main/java/org/apache/hadoop/hbase/io/FileLink.java
View File

@ -36,6 +36,7 @@ import org.apache.hadoop.fs.Path;
import org.apache.hadoop.fs.PositionedReadable; import org.apache.hadoop.fs.PositionedReadable;
import org.apache.hadoop.fs.Seekable; import org.apache.hadoop.fs.Seekable;
import org.apache.hadoop.hbase.util.FSUtils; import org.apache.hadoop.hbase.util.FSUtils;
import org.apache.hadoop.ipc.RemoteException;
/** /**
* The FileLink is a sort of hardlink, that allows access to a file given a set of locations. * The FileLink is a sort of hardlink, that allows access to a file given a set of locations.
@ -302,6 +303,9 @@ public class FileLink {
return(in); return(in);
} catch (FileNotFoundException e) { } catch (FileNotFoundException e) {
// Try another file location // Try another file location
} catch (RemoteException re) {
IOException ioe = re.unwrapRemoteException(FileNotFoundException.class);
if (!(ioe instanceof FileNotFoundException)) throw re;
} }
} }
throw new FileNotFoundException("Unable to open link: " + fileLink); throw new FileNotFoundException("Unable to open link: " + fileLink);

31
hbase-server/src/test/java/org/apache/hadoop/hbase/io/TestFileLink.java
View File

@ -36,7 +36,9 @@ import org.apache.hadoop.fs.Path;
import org.apache.hadoop.hbase.HBaseTestingUtility; import org.apache.hadoop.hbase.HBaseTestingUtility;
import org.apache.hadoop.hbase.testclassification.MediumTests; import org.apache.hadoop.hbase.testclassification.MediumTests;
import org.apache.hadoop.hbase.util.FSUtils; import org.apache.hadoop.hbase.util.FSUtils;
import org.apache.hadoop.hdfs.DistributedFileSystem;
import org.apache.hadoop.hdfs.MiniDFSCluster; import org.apache.hadoop.hdfs.MiniDFSCluster;
import org.apache.hadoop.ipc.RemoteException;
import org.junit.Test; import org.junit.Test;
import org.junit.experimental.categories.Category; import org.junit.experimental.categories.Category;
@ -104,6 +106,35 @@ public class TestFileLink {
} }
} }
private static class MyDistributedFileSystem extends DistributedFileSystem {
MyDistributedFileSystem() {
}
@Override
public FSDataInputStream open(Path f, final int bufferSize)
throws IOException {
throw new RemoteException(FileNotFoundException.class.getName(), "");
}
@Override
public Configuration getConf() {
return new Configuration();
}
}
@Test(expected = FileNotFoundException.class)
public void testLinkReadWithMissingFile() throws Exception {
HBaseTestingUtility testUtil = new HBaseTestingUtility();
FileSystem fs = new MyDistributedFileSystem();
Path originalPath = new Path(testUtil.getDefaultRootDirPath(), "test.file");
Path archivedPath = new Path(testUtil.getDefaultRootDirPath(), "archived.file");
List<Path> files = new ArrayList<Path>();
files.add(originalPath);
files.add(archivedPath);
FileLink link = new FileLink(files);
link.open(fs);
}
/** /**
* Test, on a local filesystem, that the FileLink is still readable * Test, on a local filesystem, that the FileLink is still readable
* even when the current file gets renamed. * even when the current file gets renamed.