You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Jacob Park (JIRA)" <ji...@apache.org> on 2018/03/26 18:59:00 UTC

[jira] [Created] (FLINK-9084) Upgrade cassandra-driver-core to 3.4.0 to introduce BusyPoolException retries

Jacob Park created FLINK-9084:
---------------------------------

             Summary: Upgrade cassandra-driver-core to 3.4.0 to introduce BusyPoolException retries
                 Key: FLINK-9084
                 URL: https://issues.apache.org/jira/browse/FLINK-9084
             Project: Flink
          Issue Type: Improvement
          Components: Cassandra Connector
            Reporter: Jacob Park


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.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)