Team, Presently I have added elasticsearch as a sink to a stream and inserting the json data, the problem is when I restore the application in case of crash it reprocess the data in between (meanwhile a backend application updates the document in ES) and flink reinsert the document in ES and all update to ES are lost .
I am trying for a update or insert in case document not found or do not insert if document is already there. -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
