[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/fcbfbb91 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fcbfbb91 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/fcbfbb91 Branch: refs/heads/master Commit: fcbfbb9126d458feb17527b73be1eb38a2e640f7 Parents: c5371ee 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:47 2017 +0100 ---------------------------------------------------------------------- docs/dev/connectors/cassandra.md | 2 -- 1 file changed, 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/fcbfbb91/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
