Prabhu Joseph created FLINK-28216:
-------------------------------------
Summary: Hadoop S3FileSystemFactory does not honor fs.s3.impl
Key: FLINK-28216
URL: https://issues.apache.org/jira/browse/FLINK-28216
Project: Flink
Issue Type: Improvement
Components: FileSystems
Affects Versions: 1.15.0
Reporter: Prabhu Joseph
Currently Hadoop S3FileSystemFactory has hardcoded the S3 FileSystem
implementation to S3AFileSystem. It does not allow to configure any other
implementation specified in fs.s3.impl. Suggest to read the fs.s3.impl from
Hadoop Config loaded and use the same.
{code:java}
@Override
protected org.apache.hadoop.fs.FileSystem createHadoopFileSystem() {
return new S3AFileSystem();
}{code}
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
