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

HDFS-15596: ViewHDFS#create(f, permission, cflags, bufferSize, replication, blockSize, progress, checksumOpt) should not be restricted to DFS only. (#2333). Contributed by Uma Maheswara Rao G. 

Co-authored-by: Uma Maheswara Rao G <umagangumalla@cloudera.com>
This commit is contained in:
Uma Maheswara Rao G 2020-09-24 07:07:48 -07:00 committed by GitHub
parent 486ddb73f9
commit 3ccc962b99
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/ViewDistributedFileSystem.java
View File

@ -376,7 +376,6 @@ public class ViewDistributedFileSystem extends DistributedFileSystem {
} }
@Override @Override
//DFS specific API
public FSDataOutputStream create(final Path f, final FsPermission permission, public FSDataOutputStream create(final Path f, final FsPermission permission,
final EnumSet<CreateFlag> cflags, final int bufferSize, final EnumSet<CreateFlag> cflags, final int bufferSize,
final short replication, final long blockSize, final short replication, final long blockSize,
@ -387,12 +386,8 @@ public class ViewDistributedFileSystem extends DistributedFileSystem {
.create(f, permission, cflags, bufferSize, replication, blockSize, .create(f, permission, cflags, bufferSize, replication, blockSize,
progress, checksumOpt); progress, checksumOpt);
} }
ViewFileSystemOverloadScheme.MountPathInfo<FileSystem> mountPathInfo = return vfs.create(f, permission, cflags, bufferSize, replication, blockSize,
this.vfs.getMountPathInfo(f, getConf()); progress, checksumOpt);
checkDFS(mountPathInfo.getTargetFs(), "create");
return mountPathInfo.getTargetFs()
.create(mountPathInfo.getPathOnTarget(), permission, cflags, bufferSize,
replication, blockSize, progress, checksumOpt);
} }
void checkDFS(FileSystem fs, String methodName) { void checkDFS(FileSystem fs, String methodName) {