Your functions do not need to implement RichFunction (although, each function can be a RichFunction and it should not be a problem to adapt the job). The system metrics are automatically collected. Metrics are exposed via a Reporter [1]. So you do not need to take care of the collection but rather specify where the collected metrics should be reported to.
Best, Fabian [1] https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/metrics.html#reporter 2016-12-19 9:59 GMT+01:00 otherwise777 <wou...@onzichtbaar.net>: > Thank you for your reply, > I'm afraid i still don't understand it, the part i don't understand is how > to actually analyze it. It's ok if i can just analyze the system instead of > the actual job, but how would i actually do that? > I don't have any function in my program that extends the richfunction > afaik, > so how would i call the getRuntimeContext() to print or store it? > > > > -- > View this message in context: http://apache-flink-user- > mailing-list-archive.2336050.n4.nabble.com/How-to-analyze- > space-usage-of-Flink-algorithms-tp10555p10686.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >
