Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-5080

Cassandra connector ignores saveAsync result onSuccess

    XMLWordPrintableJSON

Details

    Description

      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.

      Attachments

        Activity

          People

            Unassigned Unassigned
            jsnowacki Jakub Nowacki
            Votes:
            1 Vote for this issue
            Watchers:
            5 Start watching this issue

            Dates

              Created:
              Updated:

              Time Tracking

                Estimated:
                Original Estimate - Not Specified
                Not Specified
                Remaining:
                Remaining Estimate - 0h
                0h
                Logged:
                Time Spent - 10m
                10m