[
https://issues.apache.org/jira/browse/FLINK-5080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17323692#comment-17323692
]
Flink Jira Bot commented on FLINK-5080:
---------------------------------------
This issue is assigned but has not received an update in 7 days so it has been
labeled "stale-assigned". If you are still working on the issue, please give an
update and remove the label. If you are no longer working on the issue, please
unassign so someone else may work on it. In 7 days the issue will be
automatically unassigned.
> Cassandra connector ignores saveAsync result onSuccess
> ------------------------------------------------------
>
> Key: FLINK-5080
> URL: https://issues.apache.org/jira/browse/FLINK-5080
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Cassandra
> Affects Versions: 1.1.3
> Reporter: Jakub Nowacki
> Assignee: Aleksandr Salatich
> Priority: Major
> Labels: pull-request-available, stale-assigned
> Time Spent: 10m
> Remaining Estimate: 0h
>
> When a record is saved to Cassandra it may return a ResultSet to the callback
> given in the saveAsync; e.g. when we do {{INSERT ... IF NOT EXISTS}}, a
> ResultSet is returned with column {{applied: false}} if the record exists and
> the new record has not been inserted. Thus, we loose data in such case.
> The minimal solution would be to log the result. The best solution would be
> to add possibility of passing a custom callback; in this way we could deal
> with a success or failure in more custom way. Other solution is to add a
> possibility to pass onSuccess and onFailure functions, which would be
> executed inside the callback.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
