Hi Sendoh, That sounds like a reasonable metric to add directly to the Elasticsearch connector. Could you perhaps write a comment on that inĀ https://issues.apache.org/jira/browse/FLINK-7697?
Cheers, Gordon On 19 October 2017 at 8:57:23 PM, Sendoh (unicorn.bana...@gmail.com) wrote: Hi Flink users, Did someone use accumulator with Elasticsearch Sink? So we can better compare the last timestamps in the sink and the last timestamps in Elasticsearch, in order to see how long does it take from the Elasticsearch sink to Elasticsearch. Best, Sendoh -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/