[jira] [Created] (FLINK-16736) Expose Elasticsearch sink metric

[Shang Yuanchun (Jira)]

YangLee created FLINK-16736:
-------------------------------

             Summary: Expose Elasticsearch sink metric
                 Key: FLINK-16736
                 URL: https://issues.apache.org/jira/browse/FLINK-16736
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / ElasticSearch
            Reporter: YangLee


I found it quite useful to expose metric of sink operator via flink metric system for debugging and monitoring purpose, such as:
 * total times of bulk request
 * total size(sum) of bulk request
 * total duration(sum) spent on bulk request

with these metrics, we could derive the average size and duration.

Elasticsearch SDK already exposed all these information by BulkProcessorListenr. A simple bridge should be enough.



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