文章 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-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-06-16 来自:开发者社区

实时计算 Flink版产品使用问题之怎么配置savepoint

问题一:flinkcdc 3.0 如何配置savepoint? flinkcdc 3.0 如何配置savepoint , 我在 3.0的文档里没看到, 现在任务失败之后,还需要手动设置 同步时间吗? 参考答案: 在flink-conf里面配置检查点路径,再重新启动。 关于本问题的更多回答可点击进行查看: https:...

实时计算 Flink版产品使用问题之怎么配置savepoint
文章 2024-06-15 来自:开发者社区

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

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

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

实时计算 Flink版产品使用问题之如何从指定的savepoint恢复任务

问题一:Flink 这是为何? Flink 这是为何?我的数据库中压根没有wh_item_lending这个表 flink是1.13.6的 CDC是1.4.0 参考答案: 应该是mysql 的元数...

实时计算 Flink版产品使用问题之如何从指定的savepoint恢复任务
阿里云文档 2024-06-04

Flink产品公告(2022年及之前)

本文为您介绍实时计算Flink版2022年及之前产品公告,包括平台升级、API版本升级等。

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

实时计算 Flink版产品使用合集之测试使用initial模式,使用savepoint停掉再加上表,不会做全量同步,是什么导致的

问题一:Flink CDC中sink写mysql,表既有主键又有唯一键,不是幂等的,遇到过这种吗? Flink CDC中sink写mysql,表既有主键又有唯一键,不是幂等的,只能用精确一次语义,大佬遇到过这种吗? 参考答案: 是的,Flink CDC中sink写MySQL时,如果表既有主键又有唯一键,且不是幂等的,那么只能使用精确一次语义。在这种情况...

实时计算 Flink版产品使用合集之测试使用initial模式,使用savepoint停掉再加上表,不会做全量同步,是什么导致的
文章 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-05-23 来自:开发者社区

实时计算 Flink版产品使用合集之如何解决加字段导致的savepoint失效问题

问题一:目前有办法解决flinksql加字段导致的savepoint失效问题吗? 目前有办法解决flinksql加字段导致的savepoint失效问题吗? 参考答案: 楼主你好,阿里云Flink目前还没有原生的方式来解决在Flink SQL中添加字段导致savepoint失效的问题,但是这个问题通常出现在对现有的表结构进行更改的情况下,导致Flink无...

实时计算 Flink版产品使用合集之如何解决加字段导致的savepoint失效问题

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

产品推荐

阿里云实时计算Flink

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

+关注
AI助理

你好,我是AI助理

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

登录插画

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

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