Hi! I don't think you can do it "out-of-the-box" You can check an elasticsearch example: https://github.com/elastic/elasticsearch/issues/29799 and then you'd probably need to adjust the code at https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java#L248 . Maybe you can file an issue here: https://issues.apache.org/jira/issues/
Best, Marios On Sun, Apr 3, 2022 at 5:51 AM Yuheng Zhong <ricardozyh...@gmail.com> wrote: > Hi, > > I recently started working on a flink job using elasticsearch sql > connector. Our elasticsearch cluster required SSL certificate to be > connected and there is no option to set cert in the current version of > elasticsearch sql connector(Elasticsearch | Apache Flink > <https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/connectors/table/elasticsearch/>). > May I know if there is any way to connect ES as a sink with SSL? > > Thanks, > > Ricardo >
