文章 2024-11-19 来自:开发者社区

基于OpenLake的Flink+Paimon+EMR StarRocks流式湖仓分析

概述 在这个示例中,我们基于阿里云的EMR Serverless StarRocks构建一个游戏玩家画像和行为分析平台,该案例通过收集玩家的行为日志,进行处理和分析,并最终将分析结果通过报表的形式展现给业务人员。 数据架构图 前提条件 已开通E-MapRed...

基于OpenLake的Flink+Paimon+EMR StarRocks流式湖仓分析
阿里云文档 2024-10-14

实时计算Flink和Paimon实现流批一体

本文演示了使用实时计算Flink版和EMR Serverless Spark构建Paimon数据湖分析流程。该流程包括将数据写入OSS、进行交互式查询以及执行离线数据Compact操作。EMR Serverless Spark完全兼容Paimon,通过内置的DLF元数据与其他云产品(例如,实时计算Flink版)实现元数据互通,形成完整的流批一体化解决方案。它支持灵活的任务运行方式和参数配置,满足实...

文章 2024-08-19 来自:开发者社区

实时计算 Flink版产品使用问题之如何在EMR-Flink的Flink SOL中针对source表单独设置并行度

问题一:请问:Flink1.13.6版本除了升级flink版本外还有其他解决办法吗? 请问:Flink1.13.6版本的单节点flink出现“Apache Flink Dashboard未授权访问导致任意Jar包上传漏洞”这个问题,除了升级flink版本外还有其他解决办法吗? 参考答案: "Flink Dashboard未授权访问导致任意Jar包上传漏...

实时计算 Flink版产品使用问题之如何在EMR-Flink的Flink SOL中针对source表单独设置并行度
问答 2024-07-27 来自:开发者社区

要在DataWorks上同时使用EMR Spark和Flink应用,应该怎么选择技术架构?

要在DataWorks上同时使用EMR Spark和Flink应用,应该怎么选择技术架构?

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

有使用zeppelin连接阿里全托管的flink的吗? 非EMR-flink

有使用zeppelin连接阿里全托管的flink的吗? 非EMR-flink

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

EMR on ACK是否支持flink

EMR on ACK是否支持flink

文章 2024-06-12 来自:开发者社区

EMR Serverless Spark:结合实时计算 Flink 基于 Paimon 实现流批一体

简介 EMR Serverless Spark 版是开源大数据平台 E-MapReduce 基于 Spark 提供的一款全托管、一站式的数据计算平台。它为用户提供任务开发、调试、发布、调度和运维等全方位的产品化服务,显著简化了大数据计算的工作流程,使用户能更专注于数据分析和价值提炼。 实时计算 Flink 版是阿里云提供的全托管 Serverless Flink 云服...

EMR Serverless Spark:结合实时计算 Flink 基于 Paimon 实现流批一体
问答 2024-05-30 来自:开发者社区

emr集群flink-1.11vvp版本对应开源flink什么版本

emr集群flink-1.11vvp版本对应开源flink什么版本

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

请教一下Flink,emr-flink 的flinkSQL如何只针对source表单独设置并行度呢?

请教一下Flink,emr-flink 的flinkSQL如何只针对source表单独设置并行度呢?比如kafka source表。 kafka source表如果使用全局并行度的话灵活度会很差,全局并行度比较多的话kafka-topic也没那么多分区。

阿里云文档 2024-05-14

Flink版本调整

为了更好地融入开源生态,提供更加开放和多样化的计算服务,阿里云E-MapReduce(简称EMR)从EMR-5.17.0和EMR-3.51.0版本开始,将Flink引擎版本从Flink企业版Ververica Runtime(简称VVR)调整为Flink社区开源版本,同时引入RocksDB作为存储后端,以符合开源Flink的使用习惯。

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

产品推荐

实时计算 Flink

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

+关注
AI助理

你好,我是AI助理

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