Re: Accumulator with Elasticsearch Sink

Posted by Hung on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Accumulator-with-Elasticsearch-Sink-tp16280p16351.html

Hi Gordon,

I commented the ticket. What would you think I start to implement it as
there is no progress recently?

I see it's only about adding metrics in the following class? and anyway I
probably would have to build it soon.

https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java

The other thing I find is my usecase needs accumulator than metric, as the global status is more useful for recognizing the latency of the job, the same as the following discussion:
http://mail-archives.apache.org/mod_mbox/flink-dev/201609.mbox/[e-mail]%3E

Cheers,

Sendoh



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/