阿里云文档 2025-04-23

数据摄入YAML作业开发

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

阿里云文档 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-19 来自:开发者社区

实时计算 Flink版产品使用问题之作业的检查点失败一般是什么导致的

问题一:Flink的作业为啥kafka的消息没有sink到ADB? Flink的作业为啥kafka的消息没有sink到ADB? 参考答案: countWindowAll设置有问题 ...

实时计算 Flink版产品使用问题之作业的检查点失败一般是什么导致的
问答 2024-08-14 来自:开发者社区

Flink一个作业同步多张表到kafka 深度检查直接报错了,怎么回事?

Flink一个作业同步多张表到kafka 深度检查直接报错了,怎么回事?只同步一张表就没有问题 org.apache.flink.table.api.ValidationException: SQL validation failed. From line 195, column 6 to line 195, column 19: Unknown target column 'value__...

文章 2024-07-16 来自:开发者社区

实时计算 Flink版产品使用问题之应用程序模式的作业如何从检查点保存的地方启动

问题一:Flink中appliction 模式怎么从 checkpoint 保存的地方 启动? Flink中appliction 模式怎么从 checkpoint 保存的地方 启动? 参考答案: 检查点是自动触发的,保存点是手动触发 关于本问题的更多回答可点击进行查看: https://developer.aliy...

实时计算 Flink版产品使用问题之应用程序模式的作业如何从检查点保存的地方启动
问答 2024-07-15 来自:开发者社区

在Flink CDC中作业异常以后,会自动从检查点恢复作业,但是为什么一直恢复失败?

在Flink CDC中作业异常以后,会自动从检查点恢复作业,但是为什么一直恢复失败?请参考图片:

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

实时计算 Flink版产品使用合集之在进行数据同步作业时,有什么方法可以用于检查源端和目标端的数据一致性

问题一:Flink CDC启动yarn-session这里指定的资源,是指每提交一个任务都会使用这些资源吗? Flink CDC启动yarn-session这里指定的资源,是指每提交一个任务都会使用这些资源吗?还是一共使用这些资源? ...

实时计算 Flink版产品使用合集之在进行数据同步作业时,有什么方法可以用于检查源端和目标端的数据一致性

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

产品推荐

阿里云实时计算Flink

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

+关注