[hotfix] [core] Add old checkpoint directory config key back for compatibility.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4be3a9c8
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4be3a9c8
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/4be3a9c8

Branch: refs/heads/master
Commit: 4be3a9c8127e2e88b52803ffef37db678dbcb057
Parents: d780b78
Author: Stephan Ewen <[email protected]>
Authored: Fri Feb 16 18:01:45 2018 +0100
Committer: Stephan Ewen <[email protected]>
Committed: Sun Feb 18 22:24:35 2018 +0100

----------------------------------------------------------------------
 .../java/org/apache/flink/configuration/CheckpointingOptions.java   | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/4be3a9c8/flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java
----------------------------------------------------------------------
diff --git 
a/flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java
 
b/flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java
index 1175edb..c89aff2 100644
--- 
a/flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java
+++ 
b/flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java
@@ -84,6 +84,7 @@ public class CheckpointingOptions {
        public static final ConfigOption<String> CHECKPOINTS_DIRECTORY = 
ConfigOptions
                        .key("state.checkpoints.dir")
                        .noDefaultValue()
+                       .withDeprecatedKeys("state.backend.fs.checkpointdir")
                        .withDescription("The default directory used for 
checkpoints. Used by the state backends that write" +
                                " checkpoints to file systems 
(MemoryStateBackend, FsStateBackend, RocksDBStateBackend).");
 

Reply via email to