flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mcfongtw <...@git.apache.org>
Subject [GitHub] flink pull request #4696: [FLINK-7632] [document] Overhaul on Cassandra conn...
Date Sat, 23 Sep 2017 00:36:09 GMT
Github user mcfongtw commented on a diff in the pull request:

    --- Diff: docs/dev/connectors/cassandra.md ---
    @@ -78,76 +96,195 @@ Note that that enabling this feature will have an adverse impact
on latency.
     <p style="border-radius: 5px; padding: 5px" class="bg-danger"><b>Note</b>:
The write-ahead log functionality is currently experimental. In many cases it is sufficent
to use the connector without enabling it. Please report problems to the development mailing
    +### Checkpointing and Fault Tolerance
    +With checkpointing enabled, Cassandra Sink guarantees at-least-once delivery of action
requests to C* instance.
    -#### Example
    +<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.
    +More details on [checkpoints docs]({{ site.baseurl }}/dev/stream/state/checkpointing.html)
and [fault tolerance guarantee docs]({{ site.baseurl }}/dev/connectors/guarantees.html)
    +To enable fault tolerant guarantee, checkpointing of the topology needs to be enabled
at the execution environment:
    --- End diff --
    Very true. Thanks.


View raw message