FLINK：私はゲージが

Question

ゲージを使用することはできません追加するときに、ビルドが失敗して、ビルドが失敗している：

def open(configuration: Configuration) { 
    getRuntimeContext() 
    .getMetricGroup() 
    .gauge("RecordConverter.latency", new Gauge[Int]() { 
     @Override 
     def getValue(): Int = { 
     return latency; 
     } 
    }); 
    } 

====================== =====================

error: overloaded method value gauge with alternatives: 
[ERROR] [T, G <: org.apache.flink.metrics.Gauge[T]](x$1: String,x$2: G)G <and> 
[ERROR] [T, G <: org.apache.flink.metrics.Gauge[T]](x$1: Int, x$2: G)G 
[ERROR] cannot be applied to (String, org.apache.flink.metrics.Gauge[Int]) 
[ERROR]   .gauge("RecordConverter.latency", new Gauge[Int]() { 
[ERROR]  ^

Answer 1

明示的に設定する必要がありますタイプは次のとおりです。

.gauge[Int, Gauge[Int]]("RecordConverter.latency"...