rionmonster commented on PR #27598: URL: https://github.com/apache/flink/pull/27598#issuecomment-3900394217
@DeamonDev I took a bit of time along and had Claude double-check my work, but based on the analysis, I think we only need to touch the `CommittableCollector .of()` call as _all_ of the other calls result in transient, eventually-merged instances that do not require metric registration: The only two _live_ instances both originate from `of()` calls in: - `CommitterOperator.setup()` - `GlobalCommitterOperator.setup()` All of the remaining transient calls (i.e, those merged after serialization, etc.) leverage constructor calls including: - `CommittableCollector.copy()` - `CommittableCollector.ofLegacy()` - `CommittableCollectorSerializer.deserializeV2()` - `GlobalCommitterSerializer.deserializeV1()` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
