You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2017/11/14 14:16:06 UTC
[7/7] flink git commit: [FLINK-4500][docs] Update cassandra
documentation regarding data loss
[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 <mc...@gmail.com>
Authored: Mon Nov 13 10:17:02 2017 +0800
Committer: zentol <ch...@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