阿里云文档 2025-02-25

数据摄入YAML作业开发

实时计算Flink版基于Flink CDC,通过开发YAML作业的方式有效地实现了将数据从源端同步到目标端的数据摄入工作。本文将为您介绍数据摄入YAML作业开发的操作步骤。

问答 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...

阿里云文档 2025-02-08

数据摄入YAML作业快速入门

实时计算Flink版基于Flink CDC,通过开发YAML作业的方式有效地实现了将数据从源端同步到目标端的数据摄入工作。本文介绍如何快速构建一个YAML作业将MySQL库中的所有数据同步到StarRocks中。

阿里云文档 2025-01-21

Flink Hive SQL作业快速入门

实时计算Flink版支持使用Hive方言创建批处理作业,通过兼容Hive SQL语法增强与Hive互操作性,便于从现有Hive作业平滑迁移至实时计算管理控制台。

阿里云文档 2024-12-23

开发及部署基于Hologres连接器的 Flink DataStream作业

Hologres与Flink全托管高度兼容,多数情况下您可以使用Flink SQL的方式,声明Hologres的源表、维表及结果表,进而使用SQL表达数据的处理逻辑。但对于特殊业务场景,Flink SQL方式无法满足业务计算时,您需要使用DataStream的方式读写数据。本文以VVR-8.0.8-Flink-1.17版本为例,为您完整地展示如何调试和开发基于Hologres连接器的DataStr...

阿里云文档 2024-09-20

作业开发上线流程及规范

随着数据量的爆炸性增长和业务需求的日益复杂化,企业对实时数据处理能力的需求愈发迫切。Flink作为一种强大的流处理框架已经成为实时计算标准,其规范化的开发和运维流程对于企业提升数据处理效率、确保系统稳定性至关重要,旨在提升研发效率,保障项目顺利进行。实时计算Flink版基于Apache Flink构建了一站式开发运维管理平台,支持作业开发、数据调试、运行与监控、自动调优、智能诊断等全生命周期能力。...

文章 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 重新...

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

Flink里面的JOB能基于这个SAVEPOINT恢复作业吗?

那如果想迁移session集群给他做一个savepoint,做完之后重启SESSION集群,Flink里面的JOB能基于这个SAVEPOINT恢复作业吗?PER-JOB可以,但是SESSION我不太清楚。

文章 2022-02-14 来自:开发者社区

使用FLINK SQL从savepoint恢复hudi作业 (flink 1.13)

Flink从1.13版本开始支持在SQL Client从savepoint恢复作业。flink-savepoint介绍接下来我们从Flink SQL Client构建一个mysql cdc数据经kafka入hudi数据湖的例子。整体流程如下:在上述第二步中,我们通过手工停止kafka→hudi的Flink任务,然后在Flink SQL Client从savepoint进行恢复。下述工作类似于Fl....

使用FLINK SQL从savepoint恢复hudi作业 (flink 1.13)

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

产品推荐

实时计算 Flink

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

+关注