Re: poolingOptions not serializable?

2017-11-06 Thread Andrea Giordano
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"

Re: poolingOptions not serializable?

2017-11-06 Thread 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();

poolingOptions not serializable?

2017-11-04 Thread Andrea Giordano
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