Re: Sink Multiple Stream Elastic search

2018-08-02 Thread Timo Walther
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

Sink Multiple Stream Elastic search

2018-08-02 Thread 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.