[hotfix] Initialize FileSystem in TaskManagerRunner#main
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d9d89ff1 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d9d89ff1 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d9d89ff1 Branch: refs/heads/master Commit: d9d89ff1ea08e2053ef56bd256881f00616dd74f Parents: ab8316f Author: Till Rohrmann <[email protected]> Authored: Sat Feb 17 19:18:35 2018 +0100 Committer: Till Rohrmann <[email protected]> Committed: Sun Feb 18 10:12:54 2018 +0100 ---------------------------------------------------------------------- .../flink/runtime/taskexecutor/TaskManagerRunner.java | 9 +++++++++ 1 file changed, 9 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/d9d89ff1/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java index 2fc796d..4cb1beb 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java @@ -23,6 +23,7 @@ import org.apache.flink.api.java.utils.ParameterTool; import org.apache.flink.configuration.ConfigConstants; import org.apache.flink.configuration.Configuration; import org.apache.flink.configuration.GlobalConfiguration; +import org.apache.flink.core.fs.FileSystem; import org.apache.flink.runtime.akka.AkkaUtils; import org.apache.flink.runtime.blob.BlobCacheService; import org.apache.flink.runtime.clusterframework.types.ResourceID; @@ -53,6 +54,7 @@ import akka.actor.ActorSystem; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import java.io.IOException; import java.net.InetAddress; import java.util.concurrent.Callable; import java.util.concurrent.CompletableFuture; @@ -233,6 +235,13 @@ public class TaskManagerRunner implements FatalErrorHandler { final Configuration configuration = GlobalConfiguration.loadConfiguration(configDir); + try { + FileSystem.initialize(configuration); + } catch (IOException e) { + throw new IOException("Error while setting the default " + + "filesystem scheme from configuration.", e); + } + SecurityUtils.install(new SecurityConfiguration(configuration)); try {
