Tutorial: Getting Metrics in Stream processing systems

less than 1 minute read

Metrics for Streaming Systems

Since version 0.10.x Apache Flink provides with org.apache.flink.api.common.accumulators.Accumulator an interface to monitor running applications

IntCounter accumulator = new IntCounter(); getRuntimeContext().addAccumulator(“name”, this.accumualtor); this.accumulator.add(1);

http://mnxfst.tumblr.com/post/136539620407/receiving-metrics-from-apache-flink-applications