Repository: flink Updated Branches: refs/heads/release-1.4 8b7698dbc -> fcc79c0ed
[FLINK-4500][docs] Update cassandra documentation regarding data loss As of FLINK-4500 the Cassandra connector will wait for pending updates to finish upon checkpoint. This closes #5002. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/24970a9f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/24970a9f Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/24970a9f Branch: refs/heads/release-1.4 Commit: 24970a9f258c36c3406500ab8f383ded38c25216 Parents: c2d3d6a Author: Michael Fong <mcfong.o...@gmail.com> Authored: Mon Nov 13 10:17:02 2017 +0800 Committer: zentol <ches...@apache.org> Committed: Tue Nov 14 15:15:14 2017 +0100 ---------------------------------------------------------------------- docs/dev/connectors/cassandra.md | 2 -- 1 file changed, 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/24970a9f/docs/dev/connectors/cassandra.md ---------------------------------------------------------------------- diff --git a/docs/dev/connectors/cassandra.md b/docs/dev/connectors/cassandra.md index dd8a775..64d81b5 100644 --- a/docs/dev/connectors/cassandra.md +++ b/docs/dev/connectors/cassandra.md @@ -101,8 +101,6 @@ Note that that enabling this feature will have an adverse impact on latency. ### Checkpointing and Fault Tolerance With checkpointing enabled, Cassandra Sink guarantees at-least-once delivery of action requests to C* instance. -<p style="border-radius: 5px; padding: 5px" class="bg-danger"><b>Note</b>: However, current Cassandra Sink implementation does not flush the pending mutations before the checkpoint was triggered. Thus, some in-flight mutations might not be replayed when the job recovered. </p> - More details on [checkpoints docs]({{ site.baseurl }}/dev/stream/state/checkpointing.html) and [fault tolerance guarantee docs]({{ site.baseurl }}/dev/connectors/guarantees.html) ## Examples
