jparkie commented on issue #6782: [FLINK-9083][Cassandra Connector] Add async backpressure support to Cassandra Connector URL: https://github.com/apache/flink/pull/6782#issuecomment-427147368 I think post 3.0.4 the driver doesn’t block on executeAsync() when the internal queues are full. It throws an exception instead that it is full. Thus, as the latest driver version is 3.6.0, users can easily be using a newer version of the driver that will fail fast instead of blocking for backpressure.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
