diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileUtil.java b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileUtil.java index 4106d37e6e..312fd4d68d 100644 --- a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileUtil.java +++ b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileUtil.java @@ -1872,4 +1872,20 @@ public static FileContext write(final FileContext fileContext, final Path path, final CharSequence charseq) throws IOException { return write(fileContext, path, charseq, StandardCharsets.UTF_8); } + + @InterfaceAudience.LimitedPrivate({"ViewDistributedFileSystem"}) + @InterfaceStability.Unstable + /** + * Used in ViewDistributedFileSystem rename API to get access to the protected + * API of FileSystem interface. Even though Rename with options API + * deprecated, we are still using as part of trash. If any filesystem provided + * implementation to this protected FileSystem API, we can't invoke it with + * out casting to the specific filesystem. This util method is proposed to get + * the access to FileSystem#rename with options. + */ + @SuppressWarnings("deprecation") + public static void rename(FileSystem srcFs, Path src, Path dst, + final Options.Rename... options) throws IOException { + srcFs.rename(src, dst, options); + } } diff --git a/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/ViewDistributedFileSystem.java b/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/ViewDistributedFileSystem.java index 4fee963290..29404ae366 100644 --- a/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/ViewDistributedFileSystem.java +++ b/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/ViewDistributedFileSystem.java @@ -33,6 +33,7 @@ import org.apache.hadoop.fs.FileEncryptionInfo; import org.apache.hadoop.fs.FileStatus; import org.apache.hadoop.fs.FileSystem; +import org.apache.hadoop.fs.FileUtil; import org.apache.hadoop.fs.FsServerDefaults; import org.apache.hadoop.fs.FsStatus; import org.apache.hadoop.fs.LocatedFileStatus; @@ -542,14 +543,11 @@ public void rename(Path src, Path dst, final Options.Rename... options) return; } - // TODO: revisit ViewFileSystemOverloadScheme.MountPathInfo mountSrcPathInfo = this.vfs.getMountPathInfo(src, getConf()); - checkDFS(mountSrcPathInfo.getTargetFs(), "rename"); ViewFileSystemOverloadScheme.MountPathInfo mountDstPathInfo = - this.vfs.getMountPathInfo(src, getConf()); - checkDFS(mountDstPathInfo.getTargetFs(), "rename"); + this.vfs.getMountPathInfo(dst, getConf()); //Check both in same cluster. if (!mountSrcPathInfo.getTargetFs().getUri() @@ -558,9 +556,9 @@ public void rename(Path src, Path dst, final Options.Rename... options) "Can't rename across file systems."); } - ((DistributedFileSystem) mountSrcPathInfo.getTargetFs()) - .rename(mountSrcPathInfo.getPathOnTarget(), - mountDstPathInfo.getPathOnTarget(), options); + FileUtil.rename(mountSrcPathInfo.getTargetFs(), + mountSrcPathInfo.getPathOnTarget(), mountDstPathInfo.getPathOnTarget(), + options); } @Override diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestViewDistributedFileSystem.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestViewDistributedFileSystem.java index da0cb59a19..6582d47c69 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestViewDistributedFileSystem.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestViewDistributedFileSystem.java @@ -20,11 +20,13 @@ import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.CommonConfigurationKeys; import org.apache.hadoop.fs.FileSystem; +import org.apache.hadoop.fs.Options; import org.apache.hadoop.fs.Path; import org.apache.hadoop.fs.PathHandle; import org.apache.hadoop.fs.viewfs.ConfigUtil; import org.apache.hadoop.hdfs.protocol.HdfsConstants; import org.apache.hadoop.test.Whitebox; +import org.junit.Assert; import org.junit.Test; import java.io.IOException; @@ -89,4 +91,31 @@ public void testEmptyDelegationToken() throws IOException { } } } + + @Test + public void testRenameWithOptions() throws IOException { + Configuration conf = getTestConfiguration(); + MiniDFSCluster cluster = null; + try { + cluster = new MiniDFSCluster.Builder(conf).numDataNodes(0).build(); + URI defaultUri = + URI.create(conf.get(CommonConfigurationKeys.FS_DEFAULT_NAME_KEY)); + conf.set("fs.viewfs.mounttable." + defaultUri.getHost() + ".linkFallback", + defaultUri.toString()); + conf.setLong(CommonConfigurationKeys.FS_TRASH_INTERVAL_KEY, 30000); + try (ViewDistributedFileSystem fileSystem = + (ViewDistributedFileSystem) FileSystem.get(conf)) { + final Path testDir = new Path("/test"); + final Path renameDir = new Path("/testRename"); + fileSystem.mkdirs(testDir); + fileSystem.rename(testDir, renameDir, Options.Rename.TO_TRASH); + Assert.assertTrue(fileSystem.exists(renameDir)); + Assert.assertFalse(fileSystem.exists(testDir)); + } + } finally { + if (cluster != null) { + cluster.shutdown(); + } + } + } }