Hi,I'm not aware that multiple Flink operators can share transport connections. They usually perform independent communication with the target system. If the pressure is too high for Elasticsearch, have you thought about reducing the parallelism of the sink. Also the buffering options could help .
Regards, Timo https://ci.apache.org/projects/flink/flink-docs-release-1.5/dev/connectors/elasticsearch.html#configuring-the-internal-bulk-processor
Am 02.08.18 um 13:51 schrieb shashank734:
Hello, I am using Elastic search5 Connector. Can I use same connection while sinking multiple streams to Elastic search? Currently, I think it creates a different transport connection for each sink. I think it's creating a lot of connections with the cluster. Cause I am sinking 5-6 streams. -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
|( ! ) Warning: include(msgfooter.php): failed to open stream: No such file or directory in /var/www/git/apache-flink-users/msg11106.html on line 103|
|( ! ) Warning: include(): Failed opening 'msgfooter.php' for inclusion (include_path='.:/var/www/git') in /var/www/git/apache-flink-users/msg11106.html on line 103|