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

Upgrade cassandra-driver-core to 3.6.0 to introduce BusyPoolException retries to Cassandra Connector

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Reopened
    • Not a Priority
    • Resolution: Unresolved
    • None
    • None
    • Connectors / Cassandra

    Description

      As per https://datastax-oss.atlassian.net/browse/SPARKC-503, that exception will be thrown by executeAsync() since at least 3.1.4 as executeAsync() is fully async, so it throws that exception if the driver-side pool is busy. 

      This improvement has greatly improved the peek throughput of our Cassandra Sink Connector. It also allowed us to get all the benefits of the latest driver version.

      I would like to contribute this feature back upstream.

      Attachments

        Activity

          People

            jparkie Jacob Park
            jparkie Jacob Park
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated: