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")
}

Reply via email to