kann Zähler in Flink 1.3.2 nicht hinzufügen

Question

Ich versuche, einen Zähler in Flink wie erwähnt here hinzuzufügen, aber das Problem ist, dass counter.inc() void anstelle von Integer zurückgibt. Code für meine Metric wie unten

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

gegeben Es sollte besser funktionieren, wenn Sie Wert auf Ihre Zähler zuweisen:

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

Sie the documentation hilfreich sein können.