Skip to content

Commit

Permalink
[FLINK-9684][historyserver] HistoryServer should initialize FileSyste…
Browse files Browse the repository at this point in the history
…m before using it

This closes apache#6225.
  • Loading branch information
Ethanlm authored and sampath s committed Jul 26, 2018
1 parent 301fb00 commit 80d712f
Showing 1 changed file with 6 additions and 0 deletions.
Expand Up @@ -103,6 +103,12 @@ public static void main(String[] args) throws Exception {
LOG.info("Loading configuration from {}", configDir);
final Configuration flinkConfig = GlobalConfiguration.loadConfiguration(configDir);

try {
FileSystem.initialize(flinkConfig);
} catch (IOException e) {
throw new Exception("Error while setting the default filesystem scheme from configuration.", e);
}

// run the history server
SecurityUtils.install(new SecurityConfiguration(flinkConfig));

Expand Down

0 comments on commit 80d712f

Please sign in to comment.