[hotfix][docs][checkpointing] Fix and sync example code

is · Dec 28, 2020 · 8fc6eae · 8fc6eae
1 parent 441fc5d
commit 8fc6eae
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/docs/dev/stream/state/checkpointing.md b/docs/dev/stream/state/checkpointing.md
@@ -106,7 +106,7 @@ env.getCheckpointConfig().setMaxConcurrentCheckpoints(1);
 env.getCheckpointConfig().enableExternalizedCheckpoints(ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION);
 
 // enables the experimental unaligned checkpoints
-env.getCheckpointConfig.enableUnalignedCheckpoints();
+env.getCheckpointConfig().enableUnalignedCheckpoints();
 {% endhighlight %}
 </div>
 <div data-lang="scala" markdown="1">

diff --git a/docs/dev/stream/state/checkpointing.zh.md b/docs/dev/stream/state/checkpointing.zh.md
@@ -95,6 +95,8 @@ env.getCheckpointConfig().setMaxConcurrentCheckpoints(1);
 // 开启在 job 中止后仍然保留的 externalized checkpoints
 env.getCheckpointConfig().enableExternalizedCheckpoints(ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION);
 
+// 开启实验性的 unaligned checkpoints
+env.getCheckpointConfig().enableUnalignedCheckpoints();
 {% endhighlight %}
 </div>
 <div data-lang="scala" markdown="1">
@@ -120,6 +122,9 @@ env.getCheckpointConfig.setFailTasksOnCheckpointingErrors(false)
 
 // 同一时间只允许一个 checkpoint 进行
 env.getCheckpointConfig.setMaxConcurrentCheckpoints(1)
+
+// 开启实验性的 unaligned checkpoints
+env.getCheckpointConfig.enableUnalignedCheckpoints()
 {% endhighlight %}
 </div>
 <div data-lang="python" markdown="1">