文章 2024-02-25 来自:开发者社区

Flink部署问题之committedOffsets指标为负值如何解决

问题一:RocksDBKeyedStateBackend如何写磁盘 请问RocksDBKeyedStateBackend是何时将state序列化到磁盘的, 窗口结束时间?还是配置的checkpoint周期,谢谢*来自志愿者整理的flink邮件归档 参考答案: 看到 RocksDBWriteBatchWrapper类有 flushIfNeeded()方法...

问答 2023-12-31 来自:开发者社区

mysql是date类型字段,Flink CDC处理后是一个负值时间戳,请问这个怎么解决?

mysql是date类型字段,Flink CDC处理后是一个负值时间戳,请问这个怎么解决?

问答 2023-10-18 来自:开发者社区

有人碰到使用flink-cdc消费数据出现decimal数据太大,数据反而为负值的情况吗?

有人碰到使用flink-cdc消费数据出现decimal数据太大,数据反而为负值的情况吗?

问答 2023-10-18 来自:开发者社区

Flink CDC在使用过程中,decimal类型的数值过大会出现负值有碰到过吗 ?

Flink CDC在使用过程中,decimal类型的数值过大会出现负值有碰到过吗 ?

问答 2023-10-18 来自:开发者社区

Flink CDC在使用过程中,decimal精度的数值过大会出现负值有碰到过吗?

Flink CDC在使用过程中,decimal精度的数值过大会出现负值有碰到过吗?是不是flink-cdc-tidb中用了decimal转json导致的,flink-cdc-tidb-2.3.0

问答 2023-07-02 来自:开发者社区

Flink CDC中有没有人碰到读取tidb数据达到10的13位数后,数据就会出错,变成负值?

Flink CDC中有没有人碰到读取tidb数据达到10的13位数后,数据就会出错,变成负值?

问答 2022-02-15 来自:开发者社区

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

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等

登录插画

登录以查看您的控制台资源

管理云资源
状态一览
快捷访问