Hi all, I am trying to monitor my flink application, so I add two metric in my application. But I can not see any information on the web. The metric tab says "No metrics available". Do I miss any config? My flink version: 1.7.2 My example code: def main(args: Array[String]) {
val env = StreamExecutionEnvironment.getExecutionEnvironment env.setStreamTimeCharacteristic(TimeCharacteristic.ProcessingTime) val text = env.socketTextStream("HOST", 6666) val counts = text.flatMap(new RichFlatMapFunction[String, String] { private var counter: Counter = _ private var meter: org.apache.flink.metrics.Meter = _ override def open(parameters: Configuration): Unit = { super.open(parameters) counter = getRuntimeContext.getMetricGroup.counter("recordCounter") meter = getRuntimeContext.getMetricGroup.meter("recordMeter", new DropwizardMeterWrapper(new com.codahale.metrics.Meter())) } override def flatMap(value: String, out: Collector[String]): Unit = { val result = value.split("\\W+").filter(_.nonEmpty) result.foreach(out.collect) counter.inc(result.length) meter.markEvent(result.length) } }) .map { (_, 1L) } .keyBy(_._1) .timeWindow(Time.seconds(5)) .sum(1) .map { _.toString() } counts.addSink(new SocketClientSink[String]("HOST", 7777, new SimpleStringSchema)) env.execute("Scala SocketTextStreamWordCount Example") }