[FLINK-11195] Extend AbstractS3FileSystemFactory.createHadoopFileSystem to accept URI and Hadoop Configuration

• Type: Improvement
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.7.0
• Component/s: FileSystems
• Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available
• Assignee: Unassigned
• Reporter: Mark Cho
• Created: 18/Dec/18 19:50
• Updated: 30/Nov/21 22:38

Description

Currently, `createHadoopFileSystem` method does not take any parameters.

In order to delegate FileSystem creation to Hadoop FileSystem.get method, we need to pass URI and Hadoop Configuration to this abstract method.

We use a custom version of PrestoS3FileSystem by plugging our FileSystemFactory similar to `flink-filesystems/flink-s3-fs-presto` project. However, we would like to delegate our FS creation to Hadoop.

Issue Links

• links to: GitHub Pull Request #7332