You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Theo Diefenthal (Jira)" <ji...@apache.org> on 2023/02/17 12:12:00 UTC

[jira] [Created] (FLINK-31122) Expose MetricGroup to Committer of new Unified Sink v2

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)