[
https://issues.apache.org/jira/browse/FLINK-16736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Knauf updated FLINK-16736:
-------------------------------------
Labels: (was: auto-closed)
Priority: Not a Priority (was: Minor)
> 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
> Priority: Not a Priority
>
> 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)
