无法在 Flink 1.3.2 中添加计数器

Question

我正在尝试在 Flink 中添加一个计数器，但问题是 counter.inc（） 返回的是 void 而不是 Integer。我的指标代码如下

    private  static class myMetric extends RichMapFunction<String,Integer> {
       private Counter counter ;
        @Override
        public void open(Configuration parameters) throws Exception {
            super.open(parameters);
            this.getRuntimeContext().
                    getMetricGroup().
                    counter("countit");
        }
        @Override
        public Integer map(String s) throws Exception {
            return this.counter.inc();
        }
    }

Answer 1

如果为

计数器分配一个值，它应该会更好地工作：

    this.counter = getRuntimeContext()
      .getMetricGroup()
      .counter("countit");

您可能会发现该文档很有帮助。