Hi Xuyang

I am new to Flink & I don't know how to implement this dependency into the
code.
Can you please share some examples so that I can refer those.

Thanks
Nida


On Fri, Mar 22, 2024 at 7:02 AM Xuyang <xyzhong...@163.com> wrote:

> Hi, Nida.
> Can you explain more details about "unable to use it." ? Did you get an
> exception after using it?
>
>
> --
>     Best!
>     Xuyang
>
>
> 在 2024-03-21 21:14:53,"Fidea Lidea" <lideafidea...@gmail.com> 写道:
>
> Thank you Xuyang.
> I added the above flink-connector-elasticsearch dependency in my project.
> But I am unable to use it.
> Can you please share a few sample codes which are using this dependency?
>
> Thanks
> Nida
>
> On Tue, Mar 12, 2024 at 5:37 PM Xuyang <xyzhong...@163.com> wrote:
>
>> Hi, Fidea.
>> Currently, elasticsearch is not supported to be used as a source. You can
>> see the jira[1] for more details.
>> You can also cherry pick this pr[2] to your own branch and build a custom
>> elasticsearch connector to use it directly.
>>
>> [1] https://issues.apache.org/jira/browse/FLINK-25568
>> [2] https://github.com/apache/flink-connector-elasticsearch/pull/62
>>
>> --
>>     Best!
>>     Xuyang
>>
>>
>> At 2024-03-12 18:28:46, "Fidea Lidea" <lideafidea...@gmail.com> wrote:
>>
>> Hi ,
>>
>> I am trying to read data from elasticsearch & store in a stream.
>> Could you please share a few examples to *read*/get all data from
>> Elasticsearch using java.
>>
>>
>> Thanks,
>>
>>
>>
>>

Reply via email to