Flink Session jobs goes to reconciling state

Hi Team, I have a few session jobs for running jars. After creating jobs, the job goes from a running state to a reconciling state or upgrading state. How can I resolve this issue? [image: image.png] Thanks & Regards Nida Shaikh

Unable to log any data captured from kafka

Hi Team, I've written a flink job & enabled *slf4j* logging mechanism for it. Flow of* Flink Job :* Kafka source => process datastream elements(Transformations) => kafka sink. It stops logging while processing datastream. I want to log all data captured from kafka either in a log file or on the

Handle exception for an empty Datastream

Hi Team, I have written a Flink Job which reads data in a List & then converts it to stream. *Example*: public static void main(String[] args) throws Exception { // set up execution environment StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); . . . List

Re: Re: Read data from elasticsearch using Java flink

o use it." ? Did you get an > exception after using it? > > > -- > Best！ > Xuyang > > > 在 2024-03-21 21:14:53，"Fidea Lidea" 写道： > > Thank you Xuyang. > I added the above flink-connector-elasticsearch dependency in my project. > But I am u

Re: Read data from elasticsearch using Java flink

/github.com/apache/flink-connector-elasticsearch/pull/62 > > -- > Best！ > Xuyang > > > At 2024-03-12 18:28:46, "Fidea Lidea" wrote: > > Hi , > > I am trying to read data from elasticsearch & store in a stream. > Could you please s

Read data from elasticsearch using Java flink

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,

Request for sample codes for Dockerizing Java application

Hi Team, I request you to provide a few sample codes for dockerizing flink-java application. My application has only one job as of now. Awaiting your response. Thanks & Regards Nida Shaikh

Request to provide sample codes on Data stream using flink, Spring Boot & kafka

Hi Team, I request you to provide sample codes on data streaming using flink, kafka and spring boot. Awaiting your response. Thanks & Regards Nida Shaikh

Re: Request to provide example codes on ElasticsearchSinkFunction updaterequest

, > RuntimeContext ctx, > RequestIndexer indexer) { > indexer.add(createIndexRequest(element)); > } > } > > But as jiadong mentioned, ElasticsearchSinkFunction is no longer > recommended for use. > > Best, > Jiabao > > &

Request to provide example codes on ElasticsearchSinkFunction updaterequest

Hi Team, Could you please share with me a few example codes on how to perform "updaterequest on elasticsearch using apache flink" I.want to use ElasticsearchSinkFunction to perform updaterequest. Thanks Nida Shaikh lideafidea...@gmail.com