OSDir

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Do Flink metrics survive a shutdown?


I want to use Flink metrics API to store user defined metrics (counters). I instantiate the MetricsGroup in the open() function of the RichMapFunction and increment the counters which are created within the metrics group.

If the job restarts on failure, will the counters get restored from state?

Thanks,
Sameer