文章 2024-08-29 来自:开发者社区

实时计算 Flink版产品使用问题之如何从savepoint重新启动作业

问题一:怎么尝试使用 Flink CDC 3.0 按照官网案例同步 MySQL 数据库到 Doris? 我正在尝试使用 Flink CDC 3.0 按照官网案例同步 MySQL 数据库到 Doris,使用的是以下命令:bash bin/flink-cdc.sh mysql-to-doris.yaml,有人说对于新增加的表,可以通过创建 Savepoint 后再从 Savepoint 重新...

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

要是flink进程挂掉了,之前的任务还能从savepoint恢复吗?

要是flink进程挂掉了,之前的任务还能从savepoint恢复吗

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

Flink 1.15 如何通过原生增量 Savepoint 解决 Savepoint 性能较差的问题

Flink 1.15 如何通过原生增量 Savepoint 解决 Savepoint 性能较差的问题?

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

在 Flink 1.15 中,FLIP-193 提出了什么关于 Savepoint 和 Checkp

在 Flink 1.15 中,FLIP-193 提出了什么关于 Savepoint 和 Checkpoint 的改进?

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

在Flink CDC中,是不是不支持扩大采集库后从savepoint恢复?

在Flink CDC中,我看了下cdc3.1.1 的代码 scanNewlyAddedTabled 默认是false的。 是不是不支持扩大采集库后从savepoint恢复?

问答 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-07-17 来自:开发者社区

实时计算 Flink版操作报错合集之如何通过savepoint恢复Flink CDC任务

实时计算 Flink版操作报错合集之如何通过savepoint恢复Flink CDC任务

实时计算 Flink版操作报错合集之如何通过savepoint恢复Flink CDC任务
文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之新增字段后状态失效,无法使用savepoint启动,该怎么办

问题一:Flink数据源是 mysql 和官网上的一样的? Flink数据源是 mysql 和官网上的一样的? 参考答案: 第一,你去重写序列化类,第二在算子中处理 , ...

实时计算 Flink版产品使用问题之新增字段后状态失效,无法使用savepoint启动,该怎么办
文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之提交从savepoint恢复该如何完成

问题一:Flink CDC 3.0 启动后咋们如何提交从savepoint恢复? Flink CDC 3.0 启动后咋们如何提交从savepoint恢复? 参考答案: 可以参考这个链接:https://github.com/ververica/flink-cdc-connectors/issues/2940 关于本问题的更多...

实时计算 Flink版产品使用问题之提交从savepoint恢复该如何完成
问答 2024-07-15 来自:开发者社区

在Flink CDC中flink savepoint 在 s3 怎么配置,有人用过吗?

在Flink CDC中flink savepoint 在 s3 怎么配置,有人用过吗?

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

产品推荐

阿里云实时计算Flink

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

+关注