|
|
@@ -0,0 +1,410 @@
|
|
|
+/**
|
|
|
+ * Licensed to the Apache Software Foundation (ASF) under one
|
|
|
+ * or more contributor license agreements. See the NOTICE file
|
|
|
+ * distributed with this work for additional information
|
|
|
+ * regarding copyright ownership. The ASF licenses this file
|
|
|
+ * to you under the Apache License, Version 2.0 (the
|
|
|
+ * "License"); you may not use this file except in compliance
|
|
|
+ * with the License. You may obtain a copy of the License at
|
|
|
+ *
|
|
|
+ * http://www.apache.org/licenses/LICENSE-2.0
|
|
|
+ *
|
|
|
+ * Unless required by applicable law or agreed to in writing, software
|
|
|
+ * distributed under the License is distributed on an "AS IS" BASIS,
|
|
|
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
|
+ * See the License for the specific language governing permissions and
|
|
|
+ * limitations under the License.
|
|
|
+ */
|
|
|
+package org.apache.hadoop.fs.viewfs;
|
|
|
+
|
|
|
+import java.io.File;
|
|
|
+import java.io.IOException;
|
|
|
+import java.net.URI;
|
|
|
+
|
|
|
+import org.apache.hadoop.conf.Configuration;
|
|
|
+import org.apache.hadoop.fs.CommonConfigurationKeys;
|
|
|
+import org.apache.hadoop.fs.FileStatus;
|
|
|
+import org.apache.hadoop.fs.FileSystem;
|
|
|
+import org.apache.hadoop.fs.FsConstants;
|
|
|
+import org.apache.hadoop.fs.Path;
|
|
|
+import org.apache.hadoop.fs.RawLocalFileSystem;
|
|
|
+import org.apache.hadoop.fs.UnsupportedFileSystemException;
|
|
|
+import org.apache.hadoop.hdfs.DFSConfigKeys;
|
|
|
+import org.apache.hadoop.hdfs.DistributedFileSystem;
|
|
|
+import org.apache.hadoop.hdfs.MiniDFSCluster;
|
|
|
+import org.apache.hadoop.security.AccessControlException;
|
|
|
+import org.apache.hadoop.test.PathUtils;
|
|
|
+import org.junit.After;
|
|
|
+import org.junit.Assert;
|
|
|
+import org.junit.Before;
|
|
|
+import org.junit.Test;
|
|
|
+
|
|
|
+/**
|
|
|
+ * Tests ViewFileSystemOverloadScheme with configured mount links.
|
|
|
+ */
|
|
|
+public class TestViewFileSystemOverloadSchemeWithHdfsScheme {
|
|
|
+ private static final String FS_IMPL_PATTERN_KEY = "fs.%s.impl";
|
|
|
+ private static final String HDFS_SCHEME = "hdfs";
|
|
|
+ private Configuration conf = null;
|
|
|
+ private MiniDFSCluster cluster = null;
|
|
|
+ private URI defaultFSURI;
|
|
|
+ private File localTargetDir;
|
|
|
+ private static final String TEST_ROOT_DIR = PathUtils
|
|
|
+ .getTestDirName(TestViewFileSystemOverloadSchemeWithHdfsScheme.class);
|
|
|
+ private static final String HDFS_USER_FOLDER = "/HDFSUser";
|
|
|
+ private static final String LOCAL_FOLDER = "/local";
|
|
|
+
|
|
|
+ @Before
|
|
|
+ public void startCluster() throws IOException {
|
|
|
+ conf = new Configuration();
|
|
|
+ conf.setBoolean(DFSConfigKeys.DFS_NAMENODE_DELEGATION_TOKEN_ALWAYS_USE_KEY,
|
|
|
+ true);
|
|
|
+ conf.set(String.format(FS_IMPL_PATTERN_KEY, HDFS_SCHEME),
|
|
|
+ ViewFileSystemOverloadScheme.class.getName());
|
|
|
+ conf.set(String.format(
|
|
|
+ FsConstants.FS_VIEWFS_OVERLOAD_SCHEME_TARGET_FS_IMPL_PATTERN,
|
|
|
+ HDFS_SCHEME), DistributedFileSystem.class.getName());
|
|
|
+ cluster = new MiniDFSCluster.Builder(conf).numDataNodes(2).build();
|
|
|
+ cluster.waitClusterUp();
|
|
|
+ defaultFSURI =
|
|
|
+ URI.create(conf.get(CommonConfigurationKeys.FS_DEFAULT_NAME_KEY));
|
|
|
+ localTargetDir = new File(TEST_ROOT_DIR, "/root/");
|
|
|
+ Assert.assertEquals(HDFS_SCHEME, defaultFSURI.getScheme()); // hdfs scheme.
|
|
|
+ }
|
|
|
+
|
|
|
+ @After
|
|
|
+ public void tearDown() throws IOException {
|
|
|
+ if (cluster != null) {
|
|
|
+ FileSystem.closeAll();
|
|
|
+ cluster.shutdown();
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ private void createLinks(boolean needFalbackLink, Path hdfsTargetPath,
|
|
|
+ Path localTragetPath) {
|
|
|
+ ConfigUtil.addLink(conf, defaultFSURI.getAuthority(), HDFS_USER_FOLDER,
|
|
|
+ hdfsTargetPath.toUri());
|
|
|
+ ConfigUtil.addLink(conf, defaultFSURI.getAuthority(), LOCAL_FOLDER,
|
|
|
+ localTragetPath.toUri());
|
|
|
+ if (needFalbackLink) {
|
|
|
+ ConfigUtil.addLinkFallback(conf, defaultFSURI.getAuthority(),
|
|
|
+ hdfsTargetPath.toUri());
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * Create mount links as follows.
|
|
|
+ * hdfs://localhost:xxx/HDFSUser --> hdfs://localhost:xxx/HDFSUser/
|
|
|
+ * hdfs://localhost:xxx/local --> file://TEST_ROOT_DIR/root/
|
|
|
+ *
|
|
|
+ * create file /HDFSUser/testfile should create in hdfs
|
|
|
+ * create file /local/test should create directory in local fs
|
|
|
+ */
|
|
|
+ @Test(timeout = 30000)
|
|
|
+ public void testMountLinkWithLocalAndHDFS() throws Exception {
|
|
|
+ final Path hdfsTargetPath = new Path(defaultFSURI + HDFS_USER_FOLDER);
|
|
|
+ final Path localTragetPath = new Path(localTargetDir.toURI());
|
|
|
+
|
|
|
+ createLinks(false, hdfsTargetPath, localTragetPath);
|
|
|
+
|
|
|
+ // /HDFSUser/testfile
|
|
|
+ Path hdfsFile = new Path(HDFS_USER_FOLDER + "/testfile");
|
|
|
+ // /local/test
|
|
|
+ Path localDir = new Path(LOCAL_FOLDER + "/test");
|
|
|
+
|
|
|
+ try (ViewFileSystemOverloadScheme fs
|
|
|
+ = (ViewFileSystemOverloadScheme) FileSystem.get(conf)) {
|
|
|
+ Assert.assertEquals(2, fs.getMountPoints().length);
|
|
|
+ fs.createNewFile(hdfsFile); // /HDFSUser/testfile
|
|
|
+ fs.mkdirs(localDir); // /local/test
|
|
|
+ }
|
|
|
+
|
|
|
+ // Initialize HDFS and test files exist in ls or not
|
|
|
+ try (DistributedFileSystem dfs = new DistributedFileSystem()) {
|
|
|
+ dfs.initialize(defaultFSURI, conf);
|
|
|
+ Assert.assertTrue(dfs.exists(
|
|
|
+ new Path(Path.getPathWithoutSchemeAndAuthority(hdfsTargetPath),
|
|
|
+ hdfsFile.getName()))); // should be in hdfs.
|
|
|
+ Assert.assertFalse(dfs.exists(
|
|
|
+ new Path(Path.getPathWithoutSchemeAndAuthority(localTragetPath),
|
|
|
+ localDir.getName()))); // should not be in local fs.
|
|
|
+ }
|
|
|
+
|
|
|
+ try (RawLocalFileSystem lfs = new RawLocalFileSystem()) {
|
|
|
+ lfs.initialize(localTragetPath.toUri(), conf);
|
|
|
+ Assert.assertFalse(lfs.exists(
|
|
|
+ new Path(Path.getPathWithoutSchemeAndAuthority(hdfsTargetPath),
|
|
|
+ hdfsFile.getName()))); // should not be in hdfs.
|
|
|
+ Assert.assertTrue(lfs.exists(
|
|
|
+ new Path(Path.getPathWithoutSchemeAndAuthority(localTragetPath),
|
|
|
+ localDir.getName()))); // should be in local fs.
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * Create mount links as follows.
|
|
|
+ * hdfs://localhost:xxx/HDFSUser --> nonexistent://NonExistent/User/
|
|
|
+ * It should fail to add non existent fs link.
|
|
|
+ */
|
|
|
+ @Test(expected = IOException.class, timeout = 30000)
|
|
|
+ public void testMountLinkWithNonExistentLink() throws Exception {
|
|
|
+ final String userFolder = "/User";
|
|
|
+ final Path nonExistTargetPath =
|
|
|
+ new Path("nonexistent://NonExistent" + userFolder);
|
|
|
+
|
|
|
+ /**
|
|
|
+ * Below addLink will create following mount points
|
|
|
+ * hdfs://localhost:xxx/User --> nonexistent://NonExistent/User/
|
|
|
+ */
|
|
|
+ ConfigUtil.addLink(conf, defaultFSURI.getAuthority(), userFolder,
|
|
|
+ nonExistTargetPath.toUri());
|
|
|
+ FileSystem.get(conf);
|
|
|
+ Assert.fail("Expected to fail with non existent link");
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * Create mount links as follows.
|
|
|
+ * hdfs://localhost:xxx/HDFSUser --> hdfs://localhost:xxx/HDFSUser/
|
|
|
+ * hdfs://localhost:xxx/local --> file://TEST_ROOT_DIR/root/
|
|
|
+ * ListStatus on / should list the mount links.
|
|
|
+ */
|
|
|
+ @Test(timeout = 30000)
|
|
|
+ public void testListStatusOnRootShouldListAllMountLinks() throws Exception {
|
|
|
+ final Path hdfsTargetPath = new Path(defaultFSURI + HDFS_USER_FOLDER);
|
|
|
+ final Path localTragetPath = new Path(localTargetDir.toURI());
|
|
|
+
|
|
|
+ createLinks(false, hdfsTargetPath, localTragetPath);
|
|
|
+
|
|
|
+ try (FileSystem fs = FileSystem.get(conf)) {
|
|
|
+ FileStatus[] ls = fs.listStatus(new Path("/"));
|
|
|
+ Assert.assertEquals(2, ls.length);
|
|
|
+ String lsPath1 =
|
|
|
+ Path.getPathWithoutSchemeAndAuthority(ls[0].getPath()).toString();
|
|
|
+ String lsPath2 =
|
|
|
+ Path.getPathWithoutSchemeAndAuthority(ls[1].getPath()).toString();
|
|
|
+ Assert.assertTrue(
|
|
|
+ HDFS_USER_FOLDER.equals(lsPath1) || LOCAL_FOLDER.equals(lsPath1));
|
|
|
+ Assert.assertTrue(
|
|
|
+ HDFS_USER_FOLDER.equals(lsPath2) || LOCAL_FOLDER.equals(lsPath2));
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * Create mount links as follows
|
|
|
+ * hdfs://localhost:xxx/HDFSUser --> hdfs://localhost:xxx/HDFSUser/
|
|
|
+ * hdfs://localhost:xxx/local --> file://TEST_ROOT_DIR/root/
|
|
|
+ * ListStatus non mount directory should fail.
|
|
|
+ */
|
|
|
+ @Test(expected = IOException.class, timeout = 30000)
|
|
|
+ public void testListStatusOnNonMountedPath() throws Exception {
|
|
|
+ final Path hdfsTargetPath = new Path(defaultFSURI + HDFS_USER_FOLDER);
|
|
|
+ final Path localTragetPath = new Path(localTargetDir.toURI());
|
|
|
+
|
|
|
+ createLinks(false, hdfsTargetPath, localTragetPath);
|
|
|
+
|
|
|
+ try (FileSystem fs = FileSystem.get(conf)) {
|
|
|
+ fs.listStatus(new Path("/nonMount"));
|
|
|
+ Assert.fail("It should fail as no mount link with /nonMount");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * Create mount links as follows hdfs://localhost:xxx/HDFSUser -->
|
|
|
+ * hdfs://localhost:xxx/HDFSUser/ hdfs://localhost:xxx/local -->
|
|
|
+ * file://TEST_ROOT_DIR/root/ fallback --> hdfs://localhost:xxx/HDFSUser/
|
|
|
+ * Creating file or directory at non root level should succeed with fallback
|
|
|
+ * links.
|
|
|
+ */
|
|
|
+ @Test(timeout = 30000)
|
|
|
+ public void testWithLinkFallBack() throws Exception {
|
|
|
+ final Path hdfsTargetPath = new Path(defaultFSURI + HDFS_USER_FOLDER);
|
|
|
+ final Path localTragetPath = new Path(localTargetDir.toURI());
|
|
|
+
|
|
|
+ createLinks(true, hdfsTargetPath, localTragetPath);
|
|
|
+
|
|
|
+ try (FileSystem fs = FileSystem.get(conf)) {
|
|
|
+ fs.createNewFile(new Path("/nonMount/myfile"));
|
|
|
+ FileStatus[] ls = fs.listStatus(new Path("/nonMount"));
|
|
|
+ Assert.assertEquals(1, ls.length);
|
|
|
+ Assert.assertEquals(
|
|
|
+ Path.getPathWithoutSchemeAndAuthority(ls[0].getPath()).getName(),
|
|
|
+ "myfile");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * Create mount links as follows
|
|
|
+ * hdfs://localhost:xxx/HDFSUser --> hdfs://localhost:xxx/HDFSUser/
|
|
|
+ * hdfs://localhost:xxx/local --> file://TEST_ROOT_DIR/root/
|
|
|
+ *
|
|
|
+ * It cannot find any mount link. ViewFS expects a mount point from root.
|
|
|
+ */
|
|
|
+ @Test(expected = NotInMountpointException.class, timeout = 30000)
|
|
|
+ public void testCreateOnRootShouldFailWhenMountLinkConfigured()
|
|
|
+ throws Exception {
|
|
|
+ final Path hdfsTargetPath = new Path(defaultFSURI + HDFS_USER_FOLDER);
|
|
|
+ final Path localTragetPath = new Path(localTargetDir.toURI());
|
|
|
+
|
|
|
+ createLinks(false, hdfsTargetPath, localTragetPath);
|
|
|
+
|
|
|
+ try (FileSystem fs = FileSystem.get(conf)) {
|
|
|
+ fs.createNewFile(new Path("/newFileOnRoot"));
|
|
|
+ Assert.fail("It should fail as root is read only in viewFS.");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * Create mount links as follows
|
|
|
+ * hdfs://localhost:xxx/HDFSUser --> hdfs://localhost:xxx/HDFSUser/
|
|
|
+ * hdfs://localhost:xxx/local --> file://TEST_ROOT_DIR/root/
|
|
|
+ * fallback --> hdfs://localhost:xxx/HDFSUser/
|
|
|
+ *
|
|
|
+ * It will find fallback link, but root is not accessible and read only.
|
|
|
+ */
|
|
|
+ @Test(expected = AccessControlException.class, timeout = 30000)
|
|
|
+ public void testCreateOnRootShouldFailEvenFallBackMountLinkConfigured()
|
|
|
+ throws Exception {
|
|
|
+ final Path hdfsTargetPath = new Path(defaultFSURI + HDFS_USER_FOLDER);
|
|
|
+ final Path localTragetPath = new Path(localTargetDir.toURI());
|
|
|
+ createLinks(true, hdfsTargetPath, localTragetPath);
|
|
|
+ try (FileSystem fs = FileSystem.get(conf)) {
|
|
|
+ fs.createNewFile(new Path("/onRootWhenFallBack"));
|
|
|
+ Assert.fail(
|
|
|
+ "It should fail as root is read only in viewFS, even when configured"
|
|
|
+ + " with fallback.");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * Create mount links as follows
|
|
|
+ * hdfs://localhost:xxx/HDFSUser --> hdfs://localhost:xxx/HDFSUser/
|
|
|
+ * hdfs://localhost:xxx/local --> file://TEST_ROOT_DIR/root/
|
|
|
+ * fallback --> hdfs://localhost:xxx/HDFSUser/
|
|
|
+ *
|
|
|
+ * Note: Above links created because to make fs initialization success.
|
|
|
+ * Otherwise will not proceed if no mount links.
|
|
|
+ *
|
|
|
+ * Don't set fs.viewfs.overload.scheme.target.hdfs.impl property.
|
|
|
+ * So, OverloadScheme target fs initialization will fail.
|
|
|
+ */
|
|
|
+ @Test(expected = UnsupportedFileSystemException.class, timeout = 30000)
|
|
|
+ public void testInvalidOverloadSchemeTargetFS() throws Exception {
|
|
|
+ final Path hdfsTargetPath = new Path(defaultFSURI + HDFS_USER_FOLDER);
|
|
|
+ final Path localTragetPath = new Path(localTargetDir.toURI());
|
|
|
+ conf = new Configuration();
|
|
|
+ createLinks(true, hdfsTargetPath, localTragetPath);
|
|
|
+ conf.set(CommonConfigurationKeys.FS_DEFAULT_NAME_KEY,
|
|
|
+ defaultFSURI.toString());
|
|
|
+ conf.set(String.format(FS_IMPL_PATTERN_KEY, HDFS_SCHEME),
|
|
|
+ ViewFileSystemOverloadScheme.class.getName());
|
|
|
+
|
|
|
+ try (FileSystem fs = FileSystem.get(conf)) {
|
|
|
+ fs.createNewFile(new Path("/onRootWhenFallBack"));
|
|
|
+ Assert.fail("OverloadScheme target fs should be valid.");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * Create mount links as follows
|
|
|
+ * hdfs://localhost:xxx/HDFSUser --> hdfs://localhost:xxx/HDFSUser/
|
|
|
+ * hdfs://localhost:xxx/local --> file://TEST_ROOT_DIR/root/
|
|
|
+ *
|
|
|
+ * It should be able to create file using ViewFileSystemOverloadScheme.
|
|
|
+ */
|
|
|
+ @Test(timeout = 30000)
|
|
|
+ public void testViewFsOverloadSchemeWhenInnerCacheDisabled()
|
|
|
+ throws Exception {
|
|
|
+ final Path hdfsTargetPath = new Path(defaultFSURI + HDFS_USER_FOLDER);
|
|
|
+ final Path localTragetPath = new Path(localTargetDir.toURI());
|
|
|
+ createLinks(false, hdfsTargetPath, localTragetPath);
|
|
|
+ conf.setBoolean(Constants.CONFIG_VIEWFS_ENABLE_INNER_CACHE, false);
|
|
|
+ try (FileSystem fs = FileSystem.get(conf)) {
|
|
|
+ Path testFile = new Path(HDFS_USER_FOLDER + "/testFile");
|
|
|
+ fs.createNewFile(testFile);
|
|
|
+ Assert.assertTrue(fs.exists(testFile));
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * Create mount links as follows
|
|
|
+ * hdfs://localhost:xxx/HDFSUser0 --> hdfs://localhost:xxx/HDFSUser/
|
|
|
+ * hdfs://localhost:xxx/HDFSUser1 --> hdfs://localhost:xxx/HDFSUser/
|
|
|
+ *
|
|
|
+ * 1. With cache, only one hdfs child file system instance should be there.
|
|
|
+ * 2. Without cache, there should 2 hdfs instances.
|
|
|
+ */
|
|
|
+ @Test(timeout = 30000)
|
|
|
+ public void testViewFsOverloadSchemeWithInnerCache()
|
|
|
+ throws Exception {
|
|
|
+ final Path hdfsTargetPath = new Path(defaultFSURI + HDFS_USER_FOLDER);
|
|
|
+ ConfigUtil.addLink(conf, defaultFSURI.getAuthority(), HDFS_USER_FOLDER + 0,
|
|
|
+ hdfsTargetPath.toUri());
|
|
|
+ ConfigUtil.addLink(conf, defaultFSURI.getAuthority(), HDFS_USER_FOLDER + 1,
|
|
|
+ hdfsTargetPath.toUri());
|
|
|
+
|
|
|
+ // 1. Only 1 hdfs child file system should be there with cache.
|
|
|
+ try (ViewFileSystemOverloadScheme vfs =
|
|
|
+ (ViewFileSystemOverloadScheme) FileSystem.get(conf)) {
|
|
|
+ Assert.assertEquals(1, vfs.getChildFileSystems().length);
|
|
|
+ }
|
|
|
+
|
|
|
+ // 2. Two hdfs file systems should be there if no cache.
|
|
|
+ conf.setBoolean(Constants.CONFIG_VIEWFS_ENABLE_INNER_CACHE, false);
|
|
|
+ try (ViewFileSystemOverloadScheme vfs =
|
|
|
+ (ViewFileSystemOverloadScheme) FileSystem.get(conf)) {
|
|
|
+ Assert.assertEquals(2, vfs.getChildFileSystems().length);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * Create mount links as follows
|
|
|
+ * hdfs://localhost:xxx/HDFSUser0 --> hdfs://localhost:xxx/HDFSUser/
|
|
|
+ * hdfs://localhost:xxx/HDFSUser1 --> hdfs://localhost:xxx/HDFSUser/
|
|
|
+ *
|
|
|
+ * When InnerCache disabled, all matching ViewFileSystemOverloadScheme
|
|
|
+ * initialized scheme file systems would not use FileSystem cache.
|
|
|
+ */
|
|
|
+ @Test(timeout = 3000)
|
|
|
+ public void testViewFsOverloadSchemeWithNoInnerCacheAndHdfsTargets()
|
|
|
+ throws Exception {
|
|
|
+ final Path hdfsTargetPath = new Path(defaultFSURI + HDFS_USER_FOLDER);
|
|
|
+ ConfigUtil.addLink(conf, defaultFSURI.getAuthority(), HDFS_USER_FOLDER + 0,
|
|
|
+ hdfsTargetPath.toUri());
|
|
|
+ ConfigUtil.addLink(conf, defaultFSURI.getAuthority(), HDFS_USER_FOLDER + 1,
|
|
|
+ hdfsTargetPath.toUri());
|
|
|
+
|
|
|
+ conf.setBoolean(Constants.CONFIG_VIEWFS_ENABLE_INNER_CACHE, false);
|
|
|
+ // Two hdfs file systems should be there if no cache.
|
|
|
+ try (ViewFileSystemOverloadScheme vfs =
|
|
|
+ (ViewFileSystemOverloadScheme) FileSystem.get(conf)) {
|
|
|
+ Assert.assertEquals(2, vfs.getChildFileSystems().length);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * Create mount links as follows
|
|
|
+ * hdfs://localhost:xxx/local0 --> file://localPath/
|
|
|
+ * hdfs://localhost:xxx/local1 --> file://localPath/
|
|
|
+ *
|
|
|
+ * When InnerCache disabled, all non matching ViewFileSystemOverloadScheme
|
|
|
+ * initialized scheme file systems should continue to take advantage of
|
|
|
+ * FileSystem cache.
|
|
|
+ */
|
|
|
+ @Test(timeout = 3000)
|
|
|
+ public void testViewFsOverloadSchemeWithNoInnerCacheAndLocalSchemeTargets()
|
|
|
+ throws Exception {
|
|
|
+ final Path localTragetPath = new Path(localTargetDir.toURI());
|
|
|
+ ConfigUtil.addLink(conf, defaultFSURI.getAuthority(), LOCAL_FOLDER + 0,
|
|
|
+ localTragetPath.toUri());
|
|
|
+ ConfigUtil.addLink(conf, defaultFSURI.getAuthority(), LOCAL_FOLDER + 1,
|
|
|
+ localTragetPath.toUri());
|
|
|
+
|
|
|
+ // Only one local file system should be there if no InnerCache, but fs
|
|
|
+ // cache should work.
|
|
|
+ conf.setBoolean(Constants.CONFIG_VIEWFS_ENABLE_INNER_CACHE, false);
|
|
|
+ try (ViewFileSystemOverloadScheme vfs =
|
|
|
+ (ViewFileSystemOverloadScheme) FileSystem.get(conf)) {
|
|
|
+ Assert.assertEquals(1, vfs.getChildFileSystems().length);
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
Uma Maheswara Rao G