flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jakub Nowacki (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-5080) Cassandra connector ignores saveAsync result onSuccess
Date Wed, 16 Nov 2016 13:59:58 GMT
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

View raw message