Nico Kruber created FLINK-11470:
-----------------------------------
Summary: LocalEnvironment doesn't call FileSystem.initialize()
Key: FLINK-11470
URL: https://issues.apache.org/jira/browse/FLINK-11470
Project: Flink
Issue Type: Bug
Components: Local Runtime
Affects Versions: 1.6.2
Reporter: Nico Kruber
Proper Flink cluster components, e.g. task manager or job manager, initialize
configured file systems with their parsed {{Configuration}} objects. However,
the {{LocalEnvironment}} does not seem to do that and we therefore lack the
ability to configure access credentials etc like in the following example:
{code}
Configuration config = new Configuration();
config.setString("s3.access-key", "user");
config.setString("s3.secret-key", "secret");
// FileSystem.initialize(config);
final ExecutionEnvironment exEnv =
ExecutionEnvironment.createLocalEnvironment(config);
{code}
The workaround is to call {{FileSystem.initialize(config);}} yourself but it is
actually surprising that this is not done automatically.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
