Hi folks. In this metrics <document> for Flink 1.1...
# troubleshootings
Sajid Samsad
01/27/2023, 9:00 AMHi folks. In this metrics document for Flink 1.15.0, all the registered metrics are on map function. But there is no example of registering a custom metrics on a filter function.
As an experimentation, I registered some custom metrics (counter) in the filter function. But I did not see those metrics.
Is metrics collection from filter function not supported?
Sajid Samsad
01/28/2023, 11:42 AMBumping this one more time. If any folks know about this and share a bit info, that would be super useful.
s
sap1ens
01/28/2023, 5:04 PMYou should be able to use metrics with any function
sap1ens
01/28/2023, 5:04 PMAs long as it implements the Rich interface and you initialize the metric in the open method