Theo Diefenthal created FLINK-31122:
---------------------------------------
Summary: Expose MetricGroup to Committer of new Unified Sink v2
Key: FLINK-31122
URL: https://issues.apache.org/jira/browse/FLINK-31122
Project: Flink
Issue Type: Improvement
Components: Runtime / Metrics
Reporter: Theo Diefenthal
When writing my own committer, I want to include metrics on the operations
performed as for any other custom function in the pipeline.
The goal of this story is to provide MetricGroup to Committer in some way so
that in sink2.Committer, within the commit method, I somehow have access to the
MetricGroup.
The usecase for me with regards to this story: I want to notify Impala about
newly added partitions written via FileSink and track via metrics the number of
performed Impala queries and their duration.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
