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

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

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

Shang Yuanchun (Jira)
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)