[
https://issues.apache.org/jira/browse/FLINK-25857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Peter Vary updated FLINK-25857:
-------------------------------
Release Note:
The TwoPhaseCommittingSink.createCommitter method parametrization has been
changed, a new CommitterInitContext parameter has been added.
The original method will remain available during the 1.19 release line, but
they will be removed in consecutive releases.
When migrating please also consider changes introduced by FLINK-33973 and
FLIP-372
(https://cwiki.apache.org/confluence/display/FLINK/FLIP-372%3A+Enhance+and+synchronize+Sink+API+to+match+the+Source+API)
> Add committer metrics to track the status of committables
> ---------------------------------------------------------
>
> Key: FLINK-25857
> URL: https://issues.apache.org/jira/browse/FLINK-25857
> Project: Flink
> Issue Type: Sub-task
> Components: Connectors / Common
> Reporter: Fabian Paul
> Assignee: Peter Vary
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.19.0
>
> Attachments: image-2023-10-20-17-23-09-595.png, screenshot-1.png
>
>
> With Sink V2 we can now track the progress of a committable during committing
> and show metrics about the committing status. (i.e. failed, retried,
> succeeded).
> The voted FLIP
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-371%3A+Provide+initialization+context+for+Committer+creation+in+TwoPhaseCommittingSink
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
