SML0127 commented on issue #6587:
URL: https://github.com/apache/paimon/issues/6587#issuecomment-3520411545
Proposed change
Override the following methods in `HadoopSecuredFileSystem`, so they simply
delegate to the underlying fileSystem (the real FS implementation such as
`DistributedFileSystem`), which already honors the cluster configuration
```java
@Override
public FSDataOutputStream create(Path path, boolean overwrite) throws
IOException {
return runSecuredWithIOException(() -> fileSystem.create(path,
overwrite));
}
@Override
public FSDataOutputStream create(
Path path, boolean overwrite, int bufferSize, short replication,
long blockSize)
throws IOException {
return runSecuredWithIOException(
() -> fileSystem.create(path, overwrite, bufferSize,
replication, blockSize));
}
@Override
public short getDefaultReplication(Path f) {
return runSecured(() -> fileSystem.getDefaultReplication(f));
}
@Deprecated
@Override
public short getDefaultReplication() {
return runSecured(() -> fileSystem.getDefaultReplication());
}
@Override
public long getDefaultBlockSize(Path f) {
return runSecured(() -> fileSystem.getDefaultBlockSize(f));
}
@Deprecated
@Override
public long getDefaultBlockSize() {
return runSecured(() -> fileSystem.getDefaultBlockSize());
}
```
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
