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)