问答 2024-05-20 来自:开发者社区

Flink CDC里checkpoint状态进行恢复,根据报错是提示这个binlog文件已经不在了?

Flink CDC里checkpoint状态进行恢复,根据报错是提示这个binlog文件已经不在了。提示的建议方案是when_needed。这个有用吗?but this is no longer available on the server. Reconfigure the connector to use a snapshot when needed。

问答 2024-04-15 来自:开发者社区

Flink CDC里checkpoint状态进行恢复,报错提示这个binlog文件已经不在了为啥?

Flink CDC 报错 but this is no longer available on the server. Reconfigure the connector to use a snapshot when needed。这种报错无论是从checkpoint恢复,还是从timestamp或者从某个binlog文件进行恢复,应该都不行了,这个时候cdc是不是只有全量读取去恢复数据了?

问答 2024-02-06 来自:开发者社区

Flink CDC里我的flink集群的checkpoint文件是存在本地的,报错怎么解决?

Flink CDC里我的flink集群的checkpoint文件是存在本地的,然后我手动kill掉taskmanager,任务在其他机器上重启时,报错找不到checkpoint文件,这种情况怎么解决?通过state.checkpoints.dir这个配置在集群所有机器全部创建checkpoint文件么?

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

从flink CheckPoint重新拉起任务报错,1.14.5版本,有遇到过类似问题的嘛?

从flink CheckPoint重新拉起任务报错,1.14.5版本,有遇到过类似问题的嘛?通过从SavePoint、CheckPoint 两种方式都有报错,都是上面的报错从最近消费是ok的

问答 2023-11-01 来自:开发者社区

在Flink中checkpoint产生的文件名太长报错,各位大佬有遇到的吗?

代码实现mongo数据整库写hudi,采用RocksDBStateBackend状态后端,在Flink中checkpoint产生的文件名太长报错,各位大佬有遇到的吗?

问答 2023-09-06 来自:开发者社区

Flink CDC2.2 任务停止 新加表 从checkpoint恢复 会报错?

Flink CDC2.2 任务停止 新加表 从checkpoint恢复 会报错?

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

Flink CDC中checkpoint超时设置半小时还是总是失败报错什么原因?

Flink CDC中checkpoint超时设置半小时还是总是失败报错checkpoint expired beforce completing,做成非对齐得的也是,什么原因?

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

问下大家有没有遇到过Flink :checkpoint和savepoint都能正常生成,没有报错,?

问下大家有没有遇到过Flink :checkpoint和savepoint都能正常生成,没有报错,savepoint可以恢复job,checkpoint恢复时提示shared下有文件找不到,我看了下的确没有生成该文件。我的flink版本是1.16?

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

Flink CDC升级,2.3恢复用2.2的checkpoint会报错。你们咋解决的啊。。怎么才能?

问题1:Flink CDC升级,2.3恢复用2.2的checkpoint会报错。你们咋解决的啊。。怎么才能升级不报错? 问题2:怎么手动处理,cdc不是自动捕获变更吗

问答 2023-05-09 来自:开发者社区

Flink CDC 这个错误有人遇到过吗 . checkpoint保存到oss , 跑着跑着就报错了

Flink CDC 这个错误有人遇到过吗 . checkpoint保存到oss , 跑着跑着就报错了. 版本都是用的1.16.0

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

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注