[
https://issues.apache.org/jira/browse/FLINK-16736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Flink Jira Bot updated FLINK-16736:
-----------------------------------
Labels: stale-minor (was: )
> 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: Minor
> Labels: stale-minor
>
> 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)
