This is an automated email from the ASF dual-hosted git repository. tangyun pushed a commit to branch release-1.15 in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.15 by this push: new eb0f5c37ce3 [FLINK-27315][docs] Fix the demo of MemoryStateBackendMigration eb0f5c37ce3 is described below commit eb0f5c37ce34f95415fe012355a4f33d032c23cd Author: EchoLee5 <39044001+echol...@users.noreply.github.com> AuthorDate: Wed Apr 20 16:18:26 2022 +0800 [FLINK-27315][docs] Fix the demo of MemoryStateBackendMigration --- docs/content.zh/docs/ops/state/state_backends.md | 4 ++-- docs/content/docs/ops/state/state_backends.md | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/docs/content.zh/docs/ops/state/state_backends.md b/docs/content.zh/docs/ops/state/state_backends.md index 6c8c4593686..a2c81ad2939 100644 --- a/docs/content.zh/docs/ops/state/state_backends.md +++ b/docs/content.zh/docs/ops/state/state_backends.md @@ -486,14 +486,14 @@ state.checkpoint-storage: jobmanager ```java StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); env.setStateBackend(new HashMapStateBackend()); -env.getCheckpointConfig().setCheckpointStorage(new JobManagerStateBackend()); +env.getCheckpointConfig().setCheckpointStorage(new JobManagerCheckpointStorage()); ``` {{< /tab >}} {{< tab "Scala" >}} ```scala val env = StreamExecutionEnvironment.getExecutionEnvironment env.setStateBackend(new HashMapStateBackend) -env.getCheckpointConfig().setCheckpointStorage(new JobManagerStateBackend) +env.getCheckpointConfig().setCheckpointStorage(new JobManagerCheckpointStorage) ``` {{< /tab >}} {{< /tabs>}} diff --git a/docs/content/docs/ops/state/state_backends.md b/docs/content/docs/ops/state/state_backends.md index 3465de8a35f..563f2ff4641 100644 --- a/docs/content/docs/ops/state/state_backends.md +++ b/docs/content/docs/ops/state/state_backends.md @@ -477,14 +477,14 @@ state.checkpoint-storage: jobmanager ```java StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); env.setStateBackend(new HashMapStateBackend()); -env.getCheckpointConfig().setCheckpointStorage(new JobManagerStateBackend()); +env.getCheckpointConfig().setCheckpointStorage(new JobManagerCheckpointStorage()); ``` {{< /tab >}} {{< tab "Scala" >}} ```scala val env = StreamExecutionEnvironment.getExecutionEnvironment env.setStateBackend(new HashMapStateBackend) -env.getCheckpointConfig().setCheckpointStorage(new JobManagerStateBackend) +env.getCheckpointConfig().setCheckpointStorage(new JobManagerCheckpointStorage) ``` {{< /tab >}} {{< /tabs>}}