阿里云文档 2025-03-28

Flink CDC写入MaxCompute

MaxCompute为您提供对接Flink CDC的新版插件Connector连接器。您可以通过对接Flink CDC,将数据源(例如MySQL)数据实时同步至MaxCompute的目标表(普通表或Delta表)。本文为您介绍MaxCompute新版插件的能力支持情况与主要操作流程。

问答 2025-02-27 来自:开发者社区

flink cdc 3.0支持手动savepoint,然后从停止job,然后从检查点启动job吗

flink cdc 3.0支持手动savepoint,然后从停止job,然后从检查点启动job吗

问答 2025-02-20 来自:开发者社区

Flink CDC任务从savepoint/checkpoints状态中恢复作业错误问题

flink CDC任务监听mysql数据。只要不是从savepoint/checkpoint中恢复,都是能成功运行并监听数据的,但是只要从savepoint/checkpoint中恢复作业,就会报如下错误:Caused by: java.lang.RuntimeException: One or more fetchers have encountered exception at org...

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

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

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

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

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

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

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

在Flink CDC中savepoint速度不稳定,怎么样排查原因?

在Flink CDC中savepoint速度不稳定,怎么样排查原因?

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

对于Flink CDC,这个不支持从savepoint恢复么?

对于Flink CDC,这个不支持从savepoint恢复么?

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

实时计算 Flink版产品使用合集之oracle cdc 抽取新增一张表 可以从savepoint恢复吗

问题一:Flink CDC实时的调度 有什么组成部分吗? Flink CDC实时的调度 有什么组成部分吗? 参考回答: Flink CDC 实时调度主要由以下几个组件组成: Flink JobManager:负责管理 Flink 程序的运行和资源分配。 Flink TaskManager:负责执行具体的任务,并将结果返回给...

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

Flink CDC这样如何制定恢复的 savepoint 呢?

Flink CDC我用了 https://nightlies.apache.org/flink/flink-cdc-docs-master/zh/ 这里面这种方式创建了从mysql到doris的job,这样如何制定恢复的 savepoint 呢?(我试了之前在flink run的 -s 参数在 flink-cdc.sh 中是不识别的)

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

产品推荐

实时计算 Flink

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

+关注
AI助理

你好,我是AI助理

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