You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2021/05/17 10:14:35 UTC
[flink] branch master updated: [FLINK-22667][docs] Add missing slash
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 5fab2da [FLINK-22667][docs] Add missing slash
5fab2da is described below
commit 5fab2da5020926e8420de7ef2639132256e8c692
Author: lys0716 <lu...@gmail.com>
AuthorDate: Mon May 17 06:14:16 2021 -0400
[FLINK-22667][docs] Add missing slash
---
docs/content/docs/dev/datastream/fault-tolerance/checkpointing.md | 4 ++--
.../org/apache/flink/runtime/state/filesystem/FsStateBackend.java | 2 +-
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/docs/content/docs/dev/datastream/fault-tolerance/checkpointing.md b/docs/content/docs/dev/datastream/fault-tolerance/checkpointing.md
index c1e6297..38d15f8 100644
--- a/docs/content/docs/dev/datastream/fault-tolerance/checkpointing.md
+++ b/docs/content/docs/dev/datastream/fault-tolerance/checkpointing.md
@@ -114,7 +114,7 @@ env.getCheckpointConfig().enableExternalizedCheckpoints(
env.getCheckpointConfig().enableUnalignedCheckpoints();
// sets the checkpoint storage where checkpoint snapshots will be written
-env.getCheckpointConfig().setCheckpointStorage("hdfs://my/checkpoint/dir")
+env.getCheckpointConfig().setCheckpointStorage("hdfs:///my/checkpoint/dir")
```
{{< /tab >}}
{{< tab "Scala" >}}
@@ -146,7 +146,7 @@ env.getCheckpointConfig.setMaxConcurrentCheckpoints(1)
env.getCheckpointConfig.enableUnalignedCheckpoints()
// sets the checkpoint storage where checkpoint snapshots will be written
-env.getCheckpointConfig.setCheckpointStorage("hdfs://my/checkpoint/dir")
+env.getCheckpointConfig.setCheckpointStorage("hdfs:///my/checkpoint/dir")
```
{{< /tab >}}
{{< tab "Python" >}}
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 fbbcc3c..68560ac 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
@@ -73,7 +73,7 @@ import static org.apache.flink.util.Preconditions.checkNotNull;
* <pre>{@code
* StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
* env.setStateBackend(new HashMapStateBackend());
- * env.getCheckpointConfig().setCheckpointStorage("hdfs://checkpoints");
+ * env.getCheckpointConfig().setCheckpointStorage("hdfs:///checkpoints");
* }</pre>
*
* <p>If you are configuring your state backend via the {@code flink-conf.yaml} please make the