Without pooling options I have no errors and all works correctly (with a
light throughput ).
Trying to raise it, flink gave me a pool busy error about Cassandra So I
used pooling options. Now when I start the program I have the problem
described here
El 6 nov. 2017 9:48, "Nicolas Guyomar"
Hi Andrea,
Do you have the error using the builder ?
PoolingOptions poolingOptions = new PoolingOptions();
poolingOptions
.setMaxRequestsPerConnection(HostDistance.LOCAL, 32768)
.setMaxRequestsPerConnection(HostDistance.REMOTE, 1);
Builder builder = Cluster.builder();
Hi,
I’m using datastax driver to use Cassandra as sink for some data streams with
Apache Flink:
I have a problem executing my application raising an error about the full
queue. I discovered that the default value is 256, probably too low for my
load, so I have raised it using poolingOptions
