阿里云文档 2025-05-27

基于DLF、RDS或Flink、OSS支持Delta Lake或Hudi存储机制

MaxCompute基于阿里云DLF、RDS或Flink、OSS产品,构建了支持Delta Lake和Hudi存储机制的湖仓一体架构。该架构中的Delta Lake和Hudi是数据湖方案中常用的存储机制,为数据湖提供流处理、批处理能力。可以通过MaxCompute查询实时数据,以便及时洞察业务数据的变化。

文章 2023-12-25 来自:开发者社区

2021年最新最全Flink系列教程__Flink容错机制(五)

day05_Flink容错机制今日目标Flink容错机制之CheckpointFlink容错机制之重启策略存储介质StateBackendCheckpoint 配置方式状态恢复和重启策略Savepoint手动重启并恢复并行度设置Flink状态管理状态就是基于 key 或者 算子 operator 的中间结果Flink state 分为两种 : Managed state - 托管状态 , Raw....

文章 2023-11-20 来自:开发者社区

Flink教程(14)- Flink高级API(容错机制)

01 引言在前面的博客,我们学习了Flink的一些高级API,有兴趣的同学可以参阅下:《Flink教程(01)- Flink知识图谱》《Flink教程(02)- Flink入门》《Flink教程(03)- Flink环境搭建》《Flink教程(04)- Flink入门案例》《Flink教程(05)- Flink原理简单分析》《Flink教程(06)- Flink批流一体API(Source示例)....

Flink教程(14)- Flink高级API(容错机制)
文章 2019-08-05 来自:开发者社区

Apache Flink 零基础入门教程(六):状态管理及容错机制

**作者:孙梦瑶整理:韩非** 本文主要分享内容如下: 状态管理的基本概念; 状态的类型与使用示例; 容错机制与故障恢复; 一.状态管理的基本概念 1.什么是状态 首先举一个无状态计算的例子:消费延迟计算。假设现在有一个消息队列,消息队列中有一个生产者持续往消费队列写入消息,多个消费者分别从消息队列中读取消息。从图上可以看出,生产者已经写入 16 条消息,Offset 停留在 15 ;有 ...

Apache Flink 零基础入门教程(六):状态管理及容错机制

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

产品推荐

阿里云实时计算Flink

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

+关注
AI助理

你好,我是AI助理

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

登录插画

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

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