You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Peidian Li (Jira)" <ji...@apache.org> on 2020/12/10 11:06:00 UTC

[jira] [Created] (FLINK-20564) Add metrics for ElasticSearch connector

Peidian Li created FLINK-20564:
----------------------------------

             Summary: Add metrics for ElasticSearch connector 
                 Key: FLINK-20564
                 URL: https://issues.apache.org/jira/browse/FLINK-20564
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / ElasticSearch
    Affects Versions: 1.12.0
            Reporter: Peidian Li


The current ElasticSearch connector lacks some metric, could we add some metrics such as P95、P99、and the failed number of BulkRequest.
We can implement it in the [BulkProcessorListener|https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java#L389] callback function.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)