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)
