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, >> >> >> >>