You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sr...@apache.org on 2018/02/19 14:31:58 UTC
flink git commit: [FLINK-8657][documentation] Fix incorrect
description for configuration of async snapshot for heap based backend
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 <su...@163.com>
Authored: Wed Feb 14 23:21:02 2018 +0800
Committer: Stefan Richter <s....@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: