xushiyan commented on a change in pull request #2398:
URL: https://github.com/apache/hudi/pull/2398#discussion_r551527561
##########
File path:
hudi-common/src/main/java/org/apache/hudi/common/fs/HoodieWrapperFileSystem.java
##########
@@ -389,28 +456,28 @@ public Path resolvePath(Path p) throws IOException {
@Override
public FSDataInputStream open(Path f) throws IOException {
- return fileSystem.open(convertToDefaultPath(f));
+ return wrapInputStream(f, fileSystem.open(convertToDefaultPath(f)));
}
@Override
public FSDataOutputStream createNonRecursive(Path f, boolean overwrite, int
bufferSize, short replication,
- long blockSize, Progressable progress) throws IOException {
+ long blockSize, Progressable
progress) throws IOException {
Path p = convertToDefaultPath(f);
return wrapOutputStream(p,
fileSystem.createNonRecursive(p, overwrite, bufferSize, replication,
blockSize, progress));
}
@Override
public FSDataOutputStream createNonRecursive(Path f, FsPermission
permission, boolean overwrite, int bufferSize,
- short replication, long blockSize, Progressable progress) throws
IOException {
+ short replication, long
blockSize, Progressable progress) throws IOException {
Path p = convertToDefaultPath(f);
return wrapOutputStream(p,
fileSystem.createNonRecursive(p, permission, overwrite, bufferSize,
replication, blockSize, progress));
}
@Override
public FSDataOutputStream createNonRecursive(Path f, FsPermission
permission, EnumSet<CreateFlag> flags,
- int bufferSize, short replication, long blockSize, Progressable
progress) throws IOException {
+ int bufferSize, short
replication, long blockSize, Progressable progress) throws IOException {
Path p = convertToDefaultPath(f);
Review comment:
@rmpifer @vinothchandar yup i'm looking into spotless setup, which does
`spotless:apply` as part of a maven phase. and the ambiguity shall be resolved
with a proper style configured.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
