回顾 | Apache Flink 1.9 版本新特性强势预告!(内含PPT下载链接)

简介: 6月29日,Apache Flink Meetup 北京站圆满落幕,Apache Flink 1.9 版本是自 Flink 1.0 之后变化最大的版本,社区对 Flink 进行大量重构并且加入了很多新 Feature。此次 Meetup 重点解读 Flink 1.9 版本新特性。

6月29日,Apache Flink Meetup 北京站圆满落幕,Apache Flink 1.9 版本是自 Flink 1.0 之后变化最大的版本,社区对 Flink 进行大量重构并且加入了很多新 Feature。此次 Meetup 重点解读 Flink 1.9 版本新特性。

▼ PPT下载 ▼

关注Apache Flink 社区公众号Ververica,回复关键字“0629PPT”即可下载Apache Flink Meetup 北京站全部嘉宾分享的PPT.

本期 Meetup 由 Apache Flink PMC 与 Committer 开场,对 Flink 1.9 版本新特性进行全面分享;阿里巴巴技术专家从 Table API 和算法层面分享 Flink 的机器学习生态;还有 Flink on Kubernetes 、Flink 1.9 版本与 Hive 的兼容性解读,以及超过千台集群、日处理条目超过 264 亿条,处理峰值超过 3.6 千万条 / s 的 Flink 在快手的应用实践。

《Apache Flink 1.9 特性解读》

杨克特 | Apache Flink Committer,阿里巴巴高级技术专家

戴资力 | Apache Flink PMC ,Ververica Software Engineer

《Apache Flink 1.9 特性解读》由鲁尼老师与戴资力老师从 Flink 1.9.0 的特性解读与未来版本计划两方面分享。新特性部分主要从 Flink 1.9.0 架构的改动、Table API & SQL、Runtime & Core 以及生态四部分内容,关于 Flink 未来的版本计划主要分享了 SQL、Runtime 以及 Flink 的周边生态。

1.Apache Flink 1.9.0 特性解读

  • 架构改动
  • Table API & SQL
  • Runtime & Core
  • 生态

2.未来版本计划

  • SQL
  • Runtime
  • 生态

《打造基于 Flink Table API 的机器学习生态》

秦江杰 | Apache Kafka PMC,阿里巴巴 高级技术专家

《打造基于 Flink Table API 的机器学习生态》由秦江杰老师分享,主要从为什么选择 TableAPI + AI 以及如何构建基于 TableAPI 的 AI 生态系统。

Why TableAPI + AI?

Build an AI Ecosystem on TableAPI

  • TableAPI enhancement
  • Iteration
  • Machine Learning Pipeline & ML Libs
  • Deep Learning on Flink (TensorFlow, PyTorch)

《基于 Flink on Kubernetes 的大数据平台》

张凯 | 阿里云 高级技术专家

任春德 | 阿里云 高级技术专家

《基于 Flink on Kubernetes 的大数据平台》由张凯老师和任春德老师分享,主要从 K8s 简介、Flink on K8s、大数据平台以及展望四个方面分享。

  • K8s 简介
  • Flink on K8s
  • 大数据平台
  • 展望

《基于 Apache Flink 的高性能机器学习算法库》

杨旭 | 阿里巴巴 资深算法专家

《基于 Apache Flink 的高性能机器学习算法库》由杨旭老师分享,杨旭老师主要分享了阿里巴巴计算平台事业部与 Flink 社区合作,开源自研的机器学习算法库,如何基于该算法库更方便地构建高性能的 Flink 机器学习作业以及基于 Flink 研发高性能机器学习算法库过程中的技术积累与收获。

  • 概论
  • 高性能机器学习算法库介绍
  • 高性能机器学习算法库的核心技术
  • 开源

《Apache Flink 在快手的应用与实践》

董亭亭 | 快手 实时计算引擎团队负责人

《Apache Flink 在快手的应用与实践》由董亭亭老师分享,主要介绍 Flink 系统在快手的应用实践,以及快手遇到的稳定性、性能等相关问题以及解决思路。例如,如何解决 interval join 场景下 rockdb backend 的性能瓶颈、大量读取历史数据时多数据源取数速度差异导致的稳定性问题等等。

Flink 在快手应用场景与规模
快手 Flink 引擎的优化与改进
未来计划

《Apache Flink 1.9 与 Hive 的兼容性》

李锐 | Apache Hive PMC,阿里巴巴技术专家

《Apache Flink 1.9 与 Hive 的兼容性》由李锐老师分享,主要介绍了 Flink 与 Hive 集成项目的背景,项目的设计与架构,在 Flink 1.9 中与 Hive 集成的进展,以及我们后续工作的计划等。

  • Flink 与 Hive 项目集成的背景
  • 设计架构
  • 项目进展
  • Q & A

以上是 Apache Flink Meetup 北京站的全部内容,感谢报名的 1000+ 同学以及到场的 600+ 同学!Flink 1.9 版本将是自 Flink 1.0 以后变化最大的一个版本,希望今天老师们的分享能够带大家对 Flink 1.9 版本有个前瞻性的了解 ,一起期待Flink 1.9 版本的正式发布!

▼ Flink 1.9 版本新特性 直播回顾 ▼

https://www.bilibili.com/video/av57447841

相关实践学习
基于Hologres+Flink搭建GitHub实时数据大屏
通过使用Flink、Hologres构建实时数仓,并通过Hologres对接BI分析工具(以DataV为例),实现海量数据实时分析.
实时计算 Flink 实战课程
如何使用实时计算 Flink 搞定数据处理难题?实时计算 Flink 极客训练营产品、技术专家齐上阵,从开源 Flink功能介绍到实时计算 Flink 优势详解,现场实操,5天即可上手! 欢迎开通实时计算 Flink 版: https://cn.aliyun.com/product/bigdata/sc Flink Forward Asia 介绍: Flink Forward 是由 Apache 官方授权,Apache Flink Community China 支持的会议,通过参会不仅可以了解到 Flink 社区的最新动态和发展计划,还可以了解到国内外一线大厂围绕 Flink 生态的生产实践经验,是 Flink 开发者和使用者不可错过的盛会。 去年经过品牌升级后的 Flink Forward Asia 吸引了超过2000人线下参与,一举成为国内最大的 Apache 顶级项目会议。结合2020年的特殊情况,Flink Forward Asia 2020 将在12月26日以线上峰会的形式与大家见面。
目录
相关文章
|
SQL 消息中间件 关系型数据库
Apache Doris Flink Connector 24.0.0 版本正式发布
该版本新增了对 Flink 1.20 的支持,并支持通过 Arrow Flight SQL 高速读取 Doris 中数据。
818 21
|
分布式计算 资源调度 大数据
大数据-110 Flink 安装部署 下载解压配置 Standalone模式启动 打包依赖(一)
大数据-110 Flink 安装部署 下载解压配置 Standalone模式启动 打包依赖(一)
616 0
|
分布式计算 资源调度 大数据
大数据-110 Flink 安装部署 下载解压配置 Standalone模式启动 打包依赖(二)
大数据-110 Flink 安装部署 下载解压配置 Standalone模式启动 打包依赖(二)
479 0
|
Oracle Java 关系型数据库
实时计算 Flink版产品使用合集之在同步Oracle数据时,需要下载并添加到项目中的jar包主要包括哪些
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
986 13
|
消息中间件 资源调度 Java
实时计算 Flink版产品使用问题之拉取代码没有这个类,但是在下载的jar包中有这个类,是什么导致的
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
|
关系型数据库 Java 分布式数据库
实时计算 Flink版操作报错合集之在使用 Python UDF 时遇到 requests 包的导入问题,提示 OpenSSL 版本不兼容如何解决
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
684 5
|
消息中间件 关系型数据库 Kafka
实时计算 Flink版操作报错之在执行任务时遇到了一个IO错误,具体表现为无法从本地主机(localhost)下载文件,该怎么解决
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
|
SQL 算法 关系型数据库
实时计算 Flink版产品使用合集之哪个版本支持使用不锁表功能
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStreamAPI、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
|
关系型数据库 MySQL 数据库
实时计算 Flink版操作报错合集之下载了mysql的cdc的demo,在本地调试时,报错:找不到这个包,该怎么办
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
437 0
|
Java Maven 流计算
在Docker跑通Flink分布式版本的WordCount
在Docker跑通Flink分布式版本的WordCount
440 0

热门文章

最新文章

推荐镜像

更多