Hi Dan, You can learn more about Flink’s metrics system at [1] You would be able to either setup a reporter that would export the metrics to an external system, or query the metrics via the REST API, or simply use Flink’s web ui to obtain them.
If I understand the second part of your question correctly - you have a persisted value in a base class, but few different function types that derive from that base class, and you are wondering what is the scope of that persisted value? If that is the question, then the scope is bound to the function address(type+id) and not to the Java instance. So it is safe. [1] - https://ci.apache.org/projects/flink/flink-docs-release-1.9/monitoring/metrics.html Happy hacking, Igal On Sunday, December 29, 2019, Dan Pettersson <dan.pettersso...@gmail.com> wrote: > Hi all > > I'm trying to get hold of some metrics from the functions that I have > created but can't find a way to get them. It's the metrics mentioned here > I'm interested about: > https://statefun.io/deployment_operations/metrics.html > Any suggestions are appreciated. > > I also have a question regarding "best practice" when dealing with > function that share business logic. Is it safe storage wise to extends an > Abstract class that holds the persistent values? > > Thanks in advance and Happy coding during the holidays :-) > > Regards > Dan >
