[FLINK-4115] Remove filesystem initialisation from FsStateBackend constructor

989c67a1 · Josh · Aljoscha Krettek · a3d1a174 · 989c67a1
隐藏空白更改
内联并排

Showing with 0 addition and 1 deletion

flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsStateBackend.java ...apache/flink/runtime/state/filesystem/FsStateBackend.java +0 -1

未找到文件。
--- 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();
 	}

 	/**