You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by bradyMk <zh...@126.com> on 2020/07/29 10:14:35 UTC
flink1.9.1 在WebUI中查看committedOffsets指标为负值
flink1.9.1
在WebUI中查看Source__Custom_Source.KafkaConsumer.topic.geek-event-target.partition.3.committedOffsets指标为负值，查看官网释义：对于每个分区，最后一次成功提交到Kafka的偏移量。
但我这里为什么是负值呢？
<http://apache-flink.147419.n8.nabble.com/file/t802/%E6%8D%95%E8%8E%B711.png>
希望能得到指导，万分感谢~
--
Sent from: http://apache-flink.147419.n8.nabble.com/
Re: flink1.9.1 在WebUI中查看committedOffsets指标为负值
Posted by bradyMk <zh...@126.com>.
好的，我去看一下，感谢您的解答~
--
Sent from: http://apache-flink.147419.n8.nabble.com/
Re: flink1.9.1 在WebUI中查看committedOffsets指标为负值
Posted by shizk233 <wa...@gmail.com>.
如JasonLee所说，你可以在FlinkKafkaConsumerBase的notifyCheckpointComplete方法中看到提交offset的逻辑。
值得注意的是，此处的chk完成指的是整个链路上的chk完成，而不是kafka source的chk完成。
JasonLee <17...@163.com> 于2020年7月30日周四 下午9:59写道：
> hi
> 提交offset到Kafka是在ck成功之后 如果没有开启ck的话 需要设置自动提交提交offset
>
>
> | |
> JasonLee
> |
> |
> 邮箱：17610775726@163.com
> |
>
> Signature is customized by Netease Mail Master
>
> 在2020年07月30日 19:37，bradyMk 写道：
> 谢谢解答~
>
> 这个确实是个不变的值，应该是没有成功提交；而且我发现了，只要是没有设置ck的任务，该指标都会显示这个值，如果设置了ck，就会正常；但是我不懂为什么会这样，请问您知道详细的原因么？
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
回复：flink1.9.1 在WebUI中查看committedOffsets指标为负值
Posted by JasonLee <17...@163.com>.
hi
提交offset到Kafka是在ck成功之后 如果没有开启ck的话 需要设置自动提交提交offset
| |
JasonLee
|
|
邮箱：17610775726@163.com
|
Signature is customized by Netease Mail Master
在2020年07月30日 19:37，bradyMk 写道：
谢谢解答~
这个确实是个不变的值，应该是没有成功提交；而且我发现了，只要是没有设置ck的任务，该指标都会显示这个值，如果设置了ck，就会正常；但是我不懂为什么会这样，请问您知道详细的原因么？
--
Sent from: http://apache-flink.147419.n8.nabble.com/
Re: flink1.9.1 在WebUI中查看committedOffsets指标为负值
Posted by bradyMk <zh...@126.com>.
谢谢解答~
这个确实是个不变的值，应该是没有成功提交；而且我发现了，只要是没有设置ck的任务，该指标都会显示这个值，如果设置了ck，就会正常；但是我不懂为什么会这样，请问您知道详细的原因么？
--
Sent from: http://apache-flink.147419.n8.nabble.com/
Re: flink1.9.1 在WebUI中查看committedOffsets指标为负值
Posted by shizk233 <wa...@gmail.com>.
可以检查下在patition3上有没有成功提交过offsets。负值可能是没有提交过情况下的默认值（我猜这是个不变值）。
bradyMk <zh...@126.com> 于2020年7月29日周三 下午6:36写道：
> flink1.9.1
>
> 在WebUI中查看Source__Custom_Source.KafkaConsumer.topic.geek-event-target.partition.3.committedOffsets指标为负值，查看官网释义：对于每个分区，最后一次成功提交到Kafka的偏移量。
> 但我这里为什么是负值呢？
> <
> http://apache-flink.147419.n8.nabble.com/file/t802/%E6%8D%95%E8%8E%B711.png>
>
>
> 希望能得到指导，万分感谢~
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
>