[DISCUSS] Reverting sink metric name changes made in 1.15

2022-10-08 Thread Qingsheng Ren
Hi devs and users, I’d like to start a discussion about reverting a breaking change about sink  metrics made in 1.15 by FLINK-26126 [1] and FLINK-26492 [2]. TL;DR All sink metrics with name “numXXXOut” defined in FLIP-33 are replace by  “numXXXSend” in FLINK-26126 and FLINK-26492. Considering me

Passing SSLContext to the ElasticSearchSink

2022-10-08 Thread Nick Levandoski
Hello, I've had an issue similar to the one reported in ticket FLINK-27054. I would like to pass the SSLContext to the ElasticSearchSink via the NetworkClientConfig class. Would this be a good solution? Thanks, Nick