Hi Ramya, Have you tried writing to ES directly from table API? You can check the ES connector for table API here: https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/table/connect.html#elasticsearch-connector
Best, Dawid On 10/01/2019 09:21, Ramya Ramamurthy wrote: > Hi, > > I am learning to Flink. With Flink 1.7.1, trying to read from Kafka and > insert to ElasticSearch. I have a kafka connector convert the data to a > Flink table. In order to insert into Elasticsearch, I have converted this > table to a datastream, in order to be able to use the ElasticSearchSink. > But the Row returned by the streams, have lost the schema. How do i convert > this to JSON before calling the Elasticsearch sink connector. Any help or > suggestions would be appreciated. > > Thanks. >
signature.asc
Description: OpenPGP digital signature
