You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Jakub Nowacki (JIRA)" <ji...@apache.org> on 2016/11/16 13:59:58 UTC
[jira] [Created] (FLINK-5080) Cassandra connector ignores saveAsync
result onSuccess
Jakub Nowacki created FLINK-5080:
------------------------------------
Summary: Cassandra connector ignores saveAsync result onSuccess
Key: FLINK-5080
URL: https://issues.apache.org/jira/browse/FLINK-5080
Project: Flink
Issue Type: Bug
Components: Cassandra Connector
Affects Versions: 1.1.3
Reporter: Jakub Nowacki
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
(v6.3.4#6332)