Hi Marios, Ravi,

Thanks for the suggestions!

On Mon, Apr 4, 2022 at 5:00 AM ☼ R Nair <ravishankar.n...@gmail.com> wrote:

> Why bother repeating effort and code?
>
> https://prestodb.io/docs/current/connector/elasticsearch.html
>
> Best,
> Ravi
>
> On Mon, 4 Apr 2022 at 04:42, Marios Trivyzas <mat...@gmail.com> wrote:
>
>>
>> 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
>>>
>>
>>

Reply via email to