From 80d712f7c3465f89760daf8b3f25f859f93a0609 Mon Sep 17 00:00:00 2001 From: Ethan Li Date: Thu, 28 Jun 2018 10:30:57 -0500 Subject: [PATCH] [FLINK-9684][historyserver] HistoryServer should initialize FileSystem before using it This closes #6225. --- .../flink/runtime/webmonitor/history/HistoryServer.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServer.java b/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServer.java index aacc935990b753..7e7e92194672f7 100644 --- a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServer.java +++ b/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServer.java @@ -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));