Hi Vijay,
If you implement the SinkFunction yourself, you can share the
OkHttpClient.Builder across all instances in the same taskmanager by using
a static field and initializing it only once (ideally in
RichSinkFunction#open).
On Tue, Oct 6, 2020 at 9:37 AM Aljoscha Krettek wrote:
> Hi,
>
> si
Hi,
since I don't know the implementation of the Sink I can only guess. I
would say you get 82 * 300 connections because you will get 82 instances
of a sink operator and each of those would then have a connection pool
of 300 connections. The individual sink instances will (potentially) run
on
HI,
Basic question on parallelism of operators and ConnectionPool to DB:
Will this result in 82 * 300 connections to InfluxDB or just 300
connections to InfluxDB ?
main() {
sink = createInfluxMonitoringSink(..);
keyStream.addSink(sink).addParallelism(82);//will this result in 82 * 300
conne
