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

我们的flink cdc程序 同步了一段时间之后 自己停了 重启应用也没用 我们需要怎么处理呢?

我们的flink cdc程序 同步了一段时间之后 自己停了 重启应用也没用 我们需要怎么处理呢?

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

用Flink CDC2.1版本的时候,有没有方式可以程序重启后只读增量的,通过开启增量检查点能行吗?

用Flink CDC2.1版本的时候,发现无论怎么改snapshot.mode的值,程序重启还是会读一遍快照,有没有方式可以程序重启后只读增量的,通过开启增量检查点能行吗?

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

Flink CDC我是在程序里面把整库同步进行了集成,用savepoint重启任务就是报错?

问题1:Flink CDC我是在程序里面把整库同步进行了集成,程序里启停任务,现在问题是同步数据时候,以前是5张表,一个任务,现在改为7张表一个任务后,用savepoint重启任务就是报错?需要设置allowNonRestoredState参数问题2:命令方式,我也看到有,就是程序里配置,一直找不到

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

Flink CDC中有没有遇到程序停了,pg插槽的状态还是激活,再重启程序说插槽被激活?

Flink CDC中有没有遇到程序停了,pg插槽的状态还是激活,再重启程序说插槽被激活?

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

请问Flinkcdc中 flink的状态如何存储,程序重启,可以继续使用这些状态?

请问Flinkcdc中 flink的状态如何存储,程序重启,可以继续使用这些状态?我用EmbeddedRocksDBStateBackend 不生效EmbeddedRocksDBStateBackend embeddedRocksDBStateBackend = new EmbeddedRocksDBStateBackend();env.setStateBackend(embeddedRocks....

问答 2023-04-19 来自:开发者社区

Flink之前有个程序就是一直重启,导致数据库的连接数都爆满了。把人家线上的业务都搞坏了,怎么办?

Flink之前有个程序就是一直重启,导致数据库的连接数都爆满了。把人家线上的业务都搞坏了,怎么办?

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

flink cdc程序在挂了重启后如何保证数据一致性

就是flink cdc程序在挂了之后,需要重启,但中间过程中有数据库增删改,如何确保重启后这部分的数据不会丢失呢?

问答 2021-12-03 来自:开发者社区

flink1.10的ddl的双流窗口join,把程序重启后出现了问题

我是用flink1.10的ddl的双流窗口join,但是当我新增字段或修改字段类型,把程序重启后,无论是从savepoint处还是checkpoint处重启都是失败,最后只能删除掉checkpoint或savepoint才能使用,但是这样会丢些数据,请问该怎么处理,非常感谢? 报错如下: Caused by: org.apache.flink.util.FlinkException: Coul.....

问答 2020-04-23 来自:开发者社区

如果我flink程序挂掉了,我从checkpoint重启的话,会从source那里重新计算,还是从中

如果我flink程序挂掉了,我从checkpoint重启的话,会从source那里重新计算,还是从中间某个算子开始计算?

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

产品推荐

阿里云实时计算Flink

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

+关注