Re: Metric on JobManager

2018-11-21 Thread bastien dine
Hi Jamie, thanks for your reponse.. Erm this will not be easy.. any idea on how to deal with the end time ? I can have some Runtime exception in my topology, so i would like to do it like : try { // Start time here env.execute() } catch (e: Expcetion) { } finally { // End time here } -

Re: Metric on JobManager

2018-11-21 Thread Jamie Grier
What you're describing is not possible. There is no runtime context or metrics you can use at that point. The best you can probably do (at least for start time) is just keep a flag in your function and log a metric once and only once when it first starts executing. On Wed, Nov 21, 2018 at 5:18 A