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

flink-cdc读取 postgresql,从savepoint重启后一直报这个错误,为什么?

flink-cdc读取 postgresql,从savepoint重启后一直报这个错误,但是SELECT * FROM pg_replication_slots where active = true;查看就一个active的 数据,为什么?【Caused by: org.postgresql.util.PSQLException: ERROR: replication slot "" is a....

文章 2024-06-15 来自:开发者社区

实时计算 Flink版产品使用问题之修改ddl能通过savepoint进行重启吗

问题一:Flink sql修改ddl能通过savepoint重启吗? Flink sql修改ddl能通过savepoint重启吗? 参考答案: 要看修改的字段有没有shuffle过 比如keyby , 关于本问题的更多回答可点击进行查看: https://developer.aliyun.com/ask/607526...

文章 2024-05-23 来自:开发者社区

实时计算 Flink版产品使用合集之pipeline如何从savepoint恢复重启

问题一:Flink CDC中解析alter语句以生成SchemaChangeEvent 好久支持pg呢? Flink CDC中[cdc-pipeline-connector][mysql] 解析alter语句以生成SchemaChangeEvent 好久支持pg呢? 参考答案: 你去看下3.1 plan,https://github.com/verve...

实时计算 Flink版产品使用合集之pipeline如何从savepoint恢复重启
问答 2024-03-26 来自:开发者社区

Flink sql修改ddl能通过savepoint重启吗?

Flink sql修改ddl能通过savepoint重启吗?

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

Flink CDC数据同步问题之用savepoint重启任务报错如何解决

问题一:请教下,使用flink cdc同步数据到hudi ,如果mysql 字段有新增,怎么弄 请教下,使用flink cdc同步数据到hudi ,如果mysql 字段有新增,怎么弄 关于本问题的更多回答可点击进行查看: https://developer.aliyun.com/ask/503721?spm=a2c6h.13066369.questio...

Flink CDC数据同步问题之用savepoint重启任务报错如何解决
问答 2023-12-11 来自:开发者社区

Flink CDC在使用MysqlCDC的时候保存savepoint之后重启,程序抛出异常?

Flink CDC在使用MysqlCDC的时候保存savepoint之后重启,程序抛出异常?the first event offset 大于了 end event offset

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

Flink CDC这个智能调优,也是保存savepoint,然后指定新的内存参数,重启一下吗?

Flink CDC这个智能调优,也是保存savepoint,然后指定新的内存参数,重启一下吗?

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

Flink CDC从savepoint重启后会有这个error日志,但是flink任务没有异常重启?

Flink CDC从savepoint重启后会有这个error日志,但是flink任务没有异常重启,这是正常日志?

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

flink run -savepoint以后,jobmanager重启以后flinkid会变化吗?

flink run -savepoint以后,jobmanager重启以后flinkid会变化吗?大佬们

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

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

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

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

产品推荐

实时计算 Flink

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

+关注