【云栖 2023】王峰：开源大数据平台 3.0 技术解读

本文整理自阿里云研究员，阿里云计算平台事业部开源大数据平台负责人王峰在 2023 云栖大会开源大数据专场的分享，演讲主题为开源大数据平台 3.0 技术解读。

Tips：点击「阅读原文」免费领取 5000CU*小时 Flink 云资源

实时化与 Serverless 

是开源大数据 3.0 时代的必然选择

阿里云开源大数据平台孵化于阿里巴巴集团内部业务。早在 2009 年，我们就开始采用开源 Hadoop 技术体系来服务阿里内部快速发展的电商业务。在阿里巴巴内部这套 Hadoop 技术体系，当时叫云梯一，当发展成熟后，开始上云。我们在阿里云上推出了第一款开源大数据产品 E-MapReduce，简称 EMR 。我们把这个定义为开源大数据平台的第一阶段，也就是 1.0 的时代，从此刻开始，真正跨入云原生时代。

随着大数据技术的演进，大数据处理从离线技术架构向实时化演进，我们开始引入了 Apache Flink 流计算技术。阿里巴巴对 Apache Flink 社区进行了非常大的资源投入，逐渐成为最大的用户和社区推动者。到现在，Apache Flink 发展成为了全球范围内流计算、实时计算的标准。同时，我们在阿里云上也推出了实时计算 Flink 版的实时计算云产品服务。

EMR 也在不断地技术演进，从传统的 Hadoop 数仓架构升级到围绕以数据湖为核心的云原生数据湖的技术架构，因此我们把实时化和数据湖这两个技术演进的趋势，称为开源大数据平台 2.0 阶段。

从今年开始，我们在思考下一段开源大数据平台如何发展演进，我们做了以下几个 3.0 架构的技术探索，以此更好地服务我们的客户。

首先，我们尝试把实时化的技术分析和数据湖的架构进行融合，我们推出了新一代的 Streaming Lakehouse 架构，也就是实时化的数仓分析架构。

第二，随着 Serverless 的架构落地不断深入，我们开始考虑什么才是云原生架构终态。今年我们将开源大数据平台所有核心的计算、存储组件几乎实现了 Serverless 化。

第三，现在已经全面进入 AI 爆发的阶段，各行各业都开始使用AI的技术进行自我的革新。我们开始考虑 AI 的融合，希望把新的 AI 技术引入大数据平台体系中，实现大数据 AI 一体化的能力，帮助平台智能化运维和数据管理。

从今年开始，我们采用了新的数据分析架构、完全云原生的架构，并深度结合 AI 结合，开启 3.0 的新架构。接下来我将选择几个 3.0 平台中最核心的技术架构特点给大家做分享：我们做了哪些事情，取得哪些成果，以及未来会如何发展。

新一代的流式湖仓

首先介绍一下，新一代的数据分析架构——流式湖仓。我相信绝大部分用户意识到传统 Hadoop Hive 数仓架构的局限性以及技术发展的趋势，都开始将传统的 Hadoop 技术向着 新一代的湖仓分析 Lakehouse 架构进行演进。

显而易见，升级到新的 Lakehouse 数据分析架构以后有很多的优势。比如，新 Lakehouse 架构是彻底的存算分离，有更好的扩展性、灵活性。同时，新的数据湖格式也带来了更好的实时支持以及查询性能的提升等。Lakehouse 架构带来的收益明显。

但是 Lakehouse 架构是不是已经完美无缺？我觉得还没有到这个地步。现在我们看到 Lakehouse 架构在实时化方向还有进一步发展的空间，这也是众多开源用户在使用 Lakehouse 架构时候遇到的痛点：当数据都迁移到 Lakehouse 这个架构上，如何去更加实时化地加速数据处理管道，如何像传统数仓一样去实时分析 Lakehouse 中的数据。

现在的湖仓，做不到完全的实时化甚至准实时化的效果。究其原因，就是数据湖的存储格式限制了实时化的发展。大家可以看到现在数据湖存储格式主要是 Iceberg、Delta、Hudi 三剑客来构建的，不同的用户和厂商会选择不同的数据库格式。但是 Iceberg 和 Delta 是面向批处理而设计的数据湖格式，与批处理的计算引擎配合更多一些，在 Lakehouse 上实现批处理，甚至可能是比较大力度的微批处理，通过 merge 来更新。这个架构无法彻底实现实时化，或者在实时化的力度上也做不到特别细粒度，比如分钟级的粒度甚至十分钟级的粒度都是非常困难的。

Hudi 的初衷是为了解决这个问题，实现实时化的数据湖格式，提升实时更新，加速数据湖的时效性。但是，目前从架构设计和工程实现效果来看，并没有达到预期，很多客户在使用 Hudi 过程中也踩了很多坑，无论是系统稳定性还是系统的运维复杂度上都面临非常大的挑战。

其实我们可以看到，究其根源还是在湖仓架构上没有一款面向数据实时更新或者实时分析而设计的数据湖格式。去年我们在 Flink 社区进行了技术探索，在 Flink 社区里启动了一个新的子项目叫 Flink Table Store，其目的是尝试看 PMF（市场的接受程度）。通过 Flink Table Store，发现设计一款真正面向实时更新的数据湖格式还是非常有必要的，尤其是跟 Flink 这种实时流式计算引擎配合，完全能在数据湖 Lakehouse 架构上，实现实时化数据链路。

为了让这个项目有更好的发展，我们今年决定把这个项目从 Flink 社区中独立出来，作为一个独立的 Apache 基金会项目去孵化，使其有一个更大的发展空间，命名为 Apache Paimon。

Paimon 是真正为实时更新而设计的数据湖格式，并且是完全开放的，不仅支持 Flink，也会支持 Spark、Presto、Trino、StarRocks 等主流计算引擎。

而且由于设计时天生就是为了实时，所以性能和稳定性都是非常好，在我们典型的应用场景下，与开源 Hudi 方案相比，阿里云流式湖仓方案 Upsert 性能提升超过 4 倍，Scan 性能提升超过 10 倍。

因此，基于 Flink 和 Paimon，我们推出新一代的流式湖仓的数据分析技术，从整个数据的实时入湖到湖上实时 ETL 数据更新，采用一整套统一的 SQL 在 Lakehouse 来进行全链路的实时数据处理。由于 Paimon 的开放性，我们完全也可以在这个架构中引入大家用得比较多的 Spark、Presto、StarRocks 这些开源分析引擎，也包括阿里云自研引擎 MaxCompute、Hologres 都可以和 Paimon 数据进行无缝对接，实现完全开放的湖仓体系，从而整个链路实现完整的生态，不仅能够实现数据全链路的实时流动，也能实现数据全链路的实时分析。这是整个 3.0 中数据分析架构中的演进趋势，推动湖仓的实时化。

全面 Serverless 化

第二个，想介绍一下产品架构，我们的产品和云原生结合也迈出了重要一步，希望开源大数据平台实现全面的 Serverless 化。其实 Serverless 这个技术已经探索了有好几年，两年前就推出了开源大数据平台的第一款 Serverless 产品—— Serverless Flink，在阿里云上有非常多的客户使用。

通过 Serverless Flink 得到很多客户的正向反馈，大家都希望使用开箱即用的开源产品。因此今年我们又推出了四款 Serverless 开源大数据产品，两款计算、两款存储。计算型选择了用户呼声最高的 Spark 和 StarRocks，这两款引擎推出了 EMR Serverless StarRocks 和即将发布的 EMR Serverless Spark 两款计算型 Serverless 产品。

同时在存储方面，我们也推出了两款 Serverless 产品，第一款是和 OSS 对象存储团队联合合作推出的 OSS-HDFS ，全托管的 Serverless HDFS 产品。还有一款是数据湖管理构建产品中推出了完全兼容 HMS 协议的全托管的 Serverless 源数据管理的服务。我们通过这几款产品的组合可以实现几乎所有大数据场景的处理和分析。

为什么一年之内快连续推出四款 Serverless 大数据产品，完全得益于我们在技术上做的沉淀。把所有对 Serverless 的需求沉淀为大数据 Serverless 平台底座，这个平台底座可以屏蔽掉阿里云各种异构硬件和资源池，提供一套完整的多租系统的管理，包括网络隔离、资源隔离等，使得我们可以快速孵化出新的 Serverless 大数据产品。

Serverless Flink

第一款产品就是 Serverless Flink，它可以连通阿里云上下游的存储，不管是数据库、数据湖，还是数据仓库、消息队列，只要是阿里云上主流的存储数据源都可以一键打通，提供一站式的 SQL 开发平台，包括智能化的运维管理服务，实现开箱即用的效果。同时我们在 Serverless Flink 产品中对 Flink 的核心引擎做了大量的优化，并且在阿里巴巴内部大量使用，相对于开源 Flink 引擎有两到三倍的性能提升，所以使用 Serverless Flink 产品不仅是方便提升开发效率，在运行效率上也会大幅节省成本。

今年上半年新推出来另外一个新的 Serverless 数据产品就是 Serverless StarRocks，主要是解决实时交互式分析 OLAP 场景用户的需求，现在 OLAP 或者实时分析也是热点。我们评估下来目前在开源界内最主流的或者最优秀的 OLAP 引擎是 StarRocks，所以我们选择了 StarRocks 在 EMR 上开通了第一款 Serverless OLAP 产品，因为 StarRocks 是一个完全向量化的 C++ 引擎，所以性能非常优秀，支持数万的并发。

Serverless StarRocks

同时在最新版本的 StarRocks 中其实也支持存算分离的架构，结合整个产品的云原生能力推出了 Virtual Warehouse 的功能可以兼顾弹性和用户业务之间的隔离性。有了这个存算分离之后，可以将 StarRocks 和数据湖进行打通。流式湖仓会在湖上沉淀出非常多实时更新的数据，这个时候利用 Serverless StarRocks 就可以去查询湖上的实时更新数据，即时查询得到一个很好的湖仓一体的效果，称之为大湖小仓的布局。

Serverless Spark

今年还有一款重磅级产品的 Serverless 产品就是 Serverless Spark。相信 Spark 在开源大数据体系中用得最多的计算引擎，也是现在 EMR 中看到最重要的一款计算引擎。

最近几年，我们不断听到用户的呼声，希望有一款真正全托管免运维 Serverless 的 Spark 产品，能够帮助客户减轻运维的负担，提升开发的效率，甚至提升运行的效率。因此今年在全面 Serverless 化的目标下投入了非常大的资源，做出了 Serverless Spark 产品，很快将进行公测和商业化。

Serverless Spark 产品其实是集成了前面两款 Flink 和 StarRocks Serverless 产品的优势，一站式开发和智能化运维都可以实现开箱即用，按量付费完全弹性，包括和数据湖的打通等等。此外我们在 Serverless Spark 里面还内置了基于 Celeborn 做的一个 Serverless 数据服务，这样就可以免除对本地盘的依赖，完全实现整个数据计算的 Serverless 化。

Serverless HDFS（OSS-HDFS）

刚才讲了几款 Serverless 计算的产品，接下来还有一款产品是非常重要，就是存储的 Serverless 产品。我们叫  Serverless HDFS，官方产品名字是 OSS-HDFS，这是和 OSS 团队一起共建出来的产品形态。

大家都知道 HDFS 已经在大数据业界被大家认为是一款事实标准的文件系统协议，随着越来越多用户把数据搬到数据湖上，同时希望继续使用 HDFS 协议来访问数据湖上的数据，这样计算都是兼容的。

因此，我们把 OSS 的数据也可以包装成一个看上去像无限大的云 HDFS，这样就可以满足很多用户的需求。所以今年联合 OSS 团队发布了 OSS-HDFS 的 Serverless 文件系统，完全兼容 HDFS 。有了这个后，很多用户就不必自己去维护本地 HDFS 集群，免除了运维的复杂度，而且完全按量付费，有非常好的弹性，结合我们计算的原仓数据可以做智能的数据分析、冷热数据分层，帮助用户更好地降本增效。

刚才也讲了 Serverless 是开源大数据 3.0 中在云原生架构上的进展，未来在 Serverless 端上会继续推出更多的产品。

更智能的开源大数据

当前 AI 全面爆发，阿里云开源大数据平台也将 AI 技术引入大数据平台体系中，帮助我们做智能化平台运维或者数据管理等。今年，我们升级了智能化运维工具 EMR Doctor、Flink Advisor，并已广泛应用于客户和阿里云内部平台运维，平均集群问题识别时间减少 30% ，集群资源有效利用率提升 75%，帮助阿里云开源大数据平台实现智能化运维和数据管理。

大家知道在 EMR 产品中运维是非常有挑战性的事情，因为 EMR 上有非常多的组件，Hadoop、Hive、Kafka、Spark、Flink、Presto 等，一旦系统出现问题怎么快速地定位问题，是一个非常让用户头疼的事情。甚至有时候即使没有出现问题，用户也希望对整个集群的资源利用率、存储效率进行提升。

之前完全都是靠人肉经验的去沉淀。前些年，我们也投入了很多的工程师帮助客户人肉解决这些问题，但近些年我们都把这些经验和知识沉淀成AI中的知识库、规则库，再结合一些传统机器学习算法和数据分析的方法，进行智能化定位问题，给用户建议，让用户优化集群，解决问题。

此外。在 Flink 产品中也做了大量的实践，推出了智能诊断的服务 Flink Advisor。可以在开发运维的全生命周期中帮助用户定位，你的任务为什么出错了，出错在哪里，怎么修正、改进。即使在你的任务没有问题的时候也依然对你的任务做健康检测，判断潜在可能出现的风险，类似于健康分这种能力，帮助用户防范于未然，给用户一些智能化的提议，让用户去优化任务。其实这背后都是采用了大数据 AI 相结合的分析技术做到的。

最后提到 AI，我觉得有一个词首先进入开发者的视线，就是向量检索。在 AI 时代，所有非结构化的数据都可以用向量来表示，关于向量检索的技术也如雨后春笋般层出不穷。目前业界各种开源向量检索技术，经过我们评估后认为 Milvus 这个技术是目前最流行的，也是用户需求量最大的向量检索技术，因此开源大数据平台也将推出全托管 Serverless 向量检索服务，基于开源的 Milvus 生态、阿里云的 PAI 机器学习平台和各种大模型组成完整的大数据 AI 一体化的技术解决方案去服务在 AI 场景下对向量检索有需求的客户。

以上就是关于开源大数据平台 3.0 的核心技术架构以及技术发展趋势的分享。我们希望这些新技术能够在产品中落地，服务客户，得到客户的反馈。

---

▼ 「精彩专题推荐」  ▼

---

▼ 「活动推荐」首购 99 元包月试用  ▼

---

▼ 关注「Apache Flink」，获取更多技术干货 ▼

   点击「阅读原文」，免费领取 5000CU*小时 Flink 云资源