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"...