org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot load user class: org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer01

ad.java:748) No JobSubmissionResult returned, please make sure you called ExecutionEnvironment.execute() -- Chandresh Pancholi Senior Software Engineer Flipkart.com Email-id:chandresh.panch...@flipkart.com Contact:08951803660

Getting below exception while submitting Jar in task manager

at org.springframework.jmx.export.MBeanExporter.registerBeanInstance(MBeanExporter.java:672) at org.springframework.jmx.export.MBeanExporter.registerBeanNameOrInstance(MBeanExporter.java:616) ... 39 more -- Chandresh Pancholi Senior Software Engineer Flipkart.com Email-id:chandresh.panch...@flipkart.com Contact:08951803660

How to add new Kafka topic to consumer

foo4 & bar1 topic? Thanks -- Chandresh Pancholi Senior Software Engineer Flipkart.com Email-id:chandresh.panch...@flipkart.com Contact:08951803660

Re: java.lang.IllegalArgumentException: The implementation of the provided ElasticsearchSinkFunction is not serializable. The object probably contains or references non-serializable fields.

ent must be as well. > > I suggest to turn your function into a named class with a constructor that > accepts the indexName. > > > On 27.03.2018 12:15, chandresh pancholi wrote: > > Flow > Producer -> Kafka(Avro) -> Flink Connector with Avro deseriser -> FLink ->

java.lang.IllegalArgumentException: The implementation of the provided ElasticsearchSinkFunction is not serializable. The object probably contains or references non-serializable fields.

ot;) .source(json); } @Override public void process(String element, RuntimeContext ctx, RequestIndexer indexer) { indexer.add(createIndexRequest(element)); } })); } } -- Chandresh Pancholi Senior Software Engineer Flipkart.com Email-id:chandresh.panch...@flipkart.com Contact:08951803660