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)
