Repository: flink Updated Branches: refs/heads/master 728a5261e -> 0cb9eb59e
[docs] Fix formatting error in description of stream checkpointing Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0cb9eb59 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0cb9eb59 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0cb9eb59 Branch: refs/heads/master Commit: 0cb9eb59ea4a968970c6280e4c72e220bacdbb42 Parents: 728a526 Author: Stephan Ewen <[email protected]> Authored: Mon Jul 6 15:31:48 2015 +0200 Committer: Stephan Ewen <[email protected]> Committed: Mon Jul 6 15:31:48 2015 +0200 ---------------------------------------------------------------------- docs/internals/stream_checkpointing.md | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/0cb9eb59/docs/internals/stream_checkpointing.md ---------------------------------------------------------------------- diff --git a/docs/internals/stream_checkpointing.md b/docs/internals/stream_checkpointing.md index d36f569..9fee117 100644 --- a/docs/internals/stream_checkpointing.md +++ b/docs/internals/stream_checkpointing.md @@ -105,6 +105,7 @@ When operators contain any form of *state*, this state must be part of the snaps Operators snapshot their state at the point in time when they received all snapshot barriers from their input streams, before emitting the barriers to their output streams. At that point, all updates to the state from records before the barriers will have been made, and no updates that depend on records from after the barriers have been applied. Because the state of a snapshot may be potentially large, it is stored in a configurable *state backend*. By default, this is the JobManager's memory, but for serious setups, a distributed reliable storage should be configured (such as HDFS). After the state has been stored, the operator acknowledges the checkpoint, emity the snapshot barrier into the output streams, and proceeds. The resulting snapshot now contains: + - For each parallel stream data source, the offset/position in the stream when the snapshot was started - For each operator, a pointer to the state that was stored as part of the snapshot
