From 989c67a13b6c23b246cb3444ca6c9406f6e4be79 Mon Sep 17 00:00:00 2001 From: Josh Date: Thu, 23 Jun 2016 22:22:40 +0100 Subject: [PATCH] [FLINK-4115] Remove filesystem initialisation from FsStateBackend constructor --- .../apache/flink/runtime/state/filesystem/FsStateBackend.java | 1 - 1 file changed, 1 deletion(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsStateBackend.java b/flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsStateBackend.java index 1f198ec41f0..f4de48cc209 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsStateBackend.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsStateBackend.java @@ -173,7 +173,6 @@ public class FsStateBackend extends AbstractStateBackend { this.fileStateThreshold = fileStateSizeThreshold; this.basePath = validateAndNormalizeUri(checkpointDataUri); - this.filesystem = this.basePath.getFileSystem(); } /** -- GitLab