Repository: flink Updated Branches: refs/heads/master fa024726b -> 5909b5bb7
[FLINK-8657][documentation] Fix incorrect description for configuration of async snapshot for heap based backend This closes #5490. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5909b5bb Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5909b5bb Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5909b5bb Branch: refs/heads/master Commit: 5909b5bb7f2cbc8b9002432b8496bcbb9056728f Parents: fa02472 Author: summerleafs <summerle...@163.com> Authored: Wed Feb 14 23:21:02 2018 +0800 Committer: Stefan Richter <s.rich...@data-artisans.com> Committed: Mon Feb 19 15:30:28 2018 +0100 ---------------------------------------------------------------------- docs/ops/state/checkpoints.md | 3 +-- docs/ops/state/state_backends.md | 6 +++--- 2 files changed, 4 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/5909b5bb/docs/ops/state/checkpoints.md ---------------------------------------------------------------------- diff --git a/docs/ops/state/checkpoints.md b/docs/ops/state/checkpoints.md index 690680f..d2df4e6 100644 --- a/docs/ops/state/checkpoints.md +++ b/docs/ops/state/checkpoints.md @@ -83,8 +83,7 @@ env.setStateBackend(new RocksDBStateBackend("hdfs:///checkpoints-data/"); ### Difference to Savepoints Externalized checkpoints have a few differences from [savepoints](savepoints.html). They -- use a state backend specific (low-level) data format, -- may be incremental, +- use a state backend specific (low-level) data format, may be incremental. - do not support Flink specific features like rescaling. ### Resuming from an externalized checkpoint http://git-wip-us.apache.org/repos/asf/flink/blob/5909b5bb/docs/ops/state/state_backends.md ---------------------------------------------------------------------- diff --git a/docs/ops/state/state_backends.md b/docs/ops/state/state_backends.md index 00e3c4f..3410623 100644 --- a/docs/ops/state/state_backends.md +++ b/docs/ops/state/state_backends.md @@ -56,11 +56,11 @@ that store the values, triggers, etc. Upon checkpoints, this state backend will snapshot the state and send it as part of the checkpoint acknowledgement messages to the JobManager (master), which stores it on its heap as well. -The MemoryStateBackend can be configured to use asynchronous snapshots. While we strongly encourage the use of asynchronous snapshots to avoid blocking pipelines, please note that this is a new feature and currently not enabled -by default. To enable this feature, users can instantiate a `MemoryStateBackend` with the corresponding boolean flag in the constructor set to `true`, e.g.: +The MemoryStateBackend can be configured to use asynchronous snapshots. While we strongly encourage the use of asynchronous snapshots to avoid blocking pipelines, please note that this is currently enabled +by default. To disable this feature, users can instantiate a `MemoryStateBackend` with the corresponding boolean flag in the constructor set to `false`(this should only used for debug), e.g.: {% highlight java %} - new MemoryStateBackend(MAX_MEM_STATE_SIZE, true); + new MemoryStateBackend(MAX_MEM_STATE_SIZE, false); {% endhighlight %} Limitations of the MemoryStateBackend:
