[
https://issues.apache.org/jira/browse/FLINK-16736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17321393#comment-17321393
]
Flink Jira Bot commented on FLINK-16736:
----------------------------------------
This issue and all of its Sub-Tasks have not been updated for 180 days. So, it
has been labeled "stale-minor". If you are still affected by this bug or are
still interested in this issue, please give an update and remove the label. In
7 days the issue will be closed automatically.
> 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)