You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by "Chen, Mason" <ma...@sony.com> on 2020/07/20 19:34:09 UTC

records-lag-max

Hi all,

I am having some trouble with the lag metric from the kafka connector. The gauge value is always reported as NaN although I’m producing events first and then starting the flink job. Anyone know how to fix this?

```
# TYPE flink_taskmanager_job_task_operator_records_lag_max gauge
flink_taskmanager_job_task_operator_records_lag_max{ … } NaN
```

Thanks,
Mason

Re: records-lag-max

Posted by "Chen, Mason" <ma...@sony.com>.

I removed an unnecessary `.keyBy()` and I’m getting the metrics again. Is this a potential bug?

From: "Chen, Mason" <ma...@sony.com>
Date: Monday, July 20, 2020 at 12:41 PM
To: "user@flink.apache.org" <us...@flink.apache.org>
Subject: records-lag-max

Hi all,

I am having some trouble with the lag metric from the kafka connector. The gauge value is always reported as NaN although I’m producing events first and then starting the flink job. Anyone know how to fix this?

```
# TYPE flink_taskmanager_job_task_operator_records_lag_max gauge
flink_taskmanager_job_task_operator_records_lag_max{ … } NaN
```

Thanks,
Mason