Apache Flink 1.12.1 发布,流处理框架

花名提莫 2021-01-20 11:47:45 ⋅ 106 阅读

Apache Flink 1.12 系列的首个 bug 修复版本 1.12.1 已经发布。该版本包含 79 个修复和优化,因此官方强烈建议所有用户都升级到 1.12.1。

Maven 依赖

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-java</artifactId>
  <version>1.12.1</version>
</dependency>
<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-streaming-java_2.11</artifactId>
  <version>1.12.1</version>
</dependency>
<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-clients_2.11</artifactId>
  <version>1.12.1</version>
</dependency>

注意事项

  • Apache Flink 1.12.1 的 DockerHub 官方映像暂时丢失。作为替代,这些映像目前放在 Flink PMC 的托管仓库中。这也是目前 Native Kubernetes 部署的默认设置。 Flink PMC 将继续与 DockerHub 团队合作以提供官方映像。
  • 由于项目空间限制,PyPI 上暂时缺少 Apache Flink 1.12.1 的源代码和 python 3.8 linux wheel 软件包。目前,有关增加空间限制的请求正在 PyPI 审核过程中。在这段时间内,用户可以根据需要手动构建软件包。

部分更新内容

  • Sub-task
    • 添加有关 maxwell-json 格式的文档
    • 重做命令行接口文档页面
    • 重做 PyFlink CLI 文档 
  • Bug
    • BlobClientTest.testGetFailsDuringStreamingForJobPermanentBlob 挂起
    • 使用 Class.forName 时加载不同的驱动程序类时出现死锁 
    • 由于超时而无法初始化 logger:引发 LoggerInitializationException 
    • 修复 ignore-parse-errors 不适用于旧版 JSON 格式 
    • ZooKeeper quorum 因缺少 log4j 库而无法开始
  • Improvement
    • 日志开始/结束状态恢复
    • 将 “Flink Architecture” 页面翻译成中文 
    • 默认情况下启用 log4j2 监视间隔 

详情请查看更新公告


全部评论: 0

    我有话说:

    40亿条/秒!Flink批一体在阿里双11首次落地的背后

    来源:王峰(莫问) Flink 中文社区原文:https://mp.weixin.qq.com/s/BTzulif0LPEbUiv2aikscA 导读:今年的双 11,实时计算处理的流量洪峰创纪录

    Apache Beam 2.25.0 发布,大数据流处理与批处理编程范式

    Apache Beam 2.25.0 发布了。Beam 是一个用于定义和执行数据处理管道的统一编程模型,包括 ETL、批处理处理。Beam 项目重点在于数据处理的编程范式和接口定义,并不涉及具体

    「轻阅读」基于 Flink SQL CDC的实时数据同步方案,附视频

    整理:陈政羽(Flink 社区志愿者)原文:https://mp.weixin.qq.com/s/QNJlacBUlkMT7ksKKSNa5Q Flink 1.11 引入了 Flink SQL

    Apache Ant 1.10.10 发布

    Apache Ant 1.10.10发布Apache Ant 是一个将软件编译、测试、部署等步骤联系在一起加以自动化的一个工具,大多用于 Java 环境中的软件开发。 Apache Ant

    微型Java开发框架Solon 1.1发布,QPS达10万+

    简介 Solon 是一个微型的Java开发框架。项目从2018年启动以来,参考过大量前人作品;历时两年,2700多次的commit;内核保持0.1m的身材,超高的Web跑分,良好的使用体验

    Pulsar Flinkconnector 2.7.0 正式发布,支持最新版 Pulsar 与 Flink

    Pulsar Flink 连接器 2.7.0 支持 Apache Pulsar 2.7.0 和 Apache Flink 1.12 中的功能,并且与 Flink连接器 和Flink 消息格式完全兼容

    Web 爬虫 Apache Nutch 1.18 发布

    Apache Nutch 1.18 发布了。Nutch是一个成熟的、可用于生产的 Web 爬虫。 Nutch 1.x 可以依靠 Apache Hadoop™ 数据结构进行细粒度配置,这对于批处理非常

    Python ORM框架SQLAlchemy 1.3.20 发布

    SQLAlchemy 1.3.20 发布了。SQLAlchemy 是一个 Python 的 SQL 工具包以及数据库对象映射(ORM)框架。它包含整套企业级持久化模式,专门用于高效和高性能的数据库

    Apache Superset 1.0 发布

    Apache 软件基金会近日宣布 Apache Superset 晋升为 ASF 顶级项目。与此同时,Apache Superset 也迎来了重大里程碑 1.0 版本

    Angular 11.1.0-next.2 发布,Web 前端框架

    Angular 11.1.0-next.2 现已发布,具体更新内容如下: Bug 修复 animations:在浏览器动画生成器中实现 getPosition compiler-cli

    Apache Beam 2.28.0 发布,大数据流处理与批处理编程范式

    Apache Beam 2.28.0 已发布,Beam 是一个用于定义和执行数据处理管道的统一编程模型,包括 ETL、批处理处理。Beam 项目重点在于数据处理的编程范式和接口定义,并不涉及具体

    Apache Tomcat 8.5.59、9.0.39和10.0.0-M9发布

    Apache Tomcat 8.5.59, 9.0.39 和 10.0.0-M9 已发布。 8.5.x 已取代 8.0.x,并增加了从 Tomcat 9.0.x 中吸收的新功能。与 8.5.58

    Apache Solr 8.8.1 发布,Java 企业级搜索引擎

    Apache Solr 8.8.1 已发布,Solr 是基于 Lucene 的全文搜索服务器,也是最流行的企业级搜索引擎,其主要功能包括全文检索、命中高亮、分面搜索、动态聚类、数据库集成

    Apache Kafka 2.7.1 发布

    Apache Kafka 2.7.1发布,这是一个 bugfix 版本,其中包括来自 45 个 JIRA 的修复和改进,还修复了部分严重的错误。 改进 [KAFKA-10852] - 优化

    VirtualBox 6.1.20 发布,支持 Linux 5.11 & 5.12

    近日,VirtualBox 发布了 6.1.20 版本,也是该软件 6.1 版本系列的第十次更新。该版本增加了对 Linux Kernel 5.11 和 5.12 的支持。而且,对于 Linux

    【开源资讯】JWCloud 专业版 v1.0.0 发布,基于 SpringCloud 研发的微服务框架

    简介 JavaWeb_Cloud 微服务平台是一款基于 SpringCloud 框架研发的分布式微服务框架,主要使用技术栈包括: SpringCloud、Vue、ElementUI

    nginx 1.19.7 主线版发布

    nginx 1.19.7 主线版已发布,此版本带来了部分变更和新特性,以及 bugfix,具体如下: 变更:HTTP/2 中对连接的处理经过修改可更好地匹配 HTTP/1.x;"http2

    Linux Kernel 5.12 rc1 发布

    Linux Kernel 5.12 rc1 已经发布。在邮件中,Linus Torvalds 表示由于美国严寒天气,其在合并窗口开始后的 6 天里是没有电的,所以曾考虑过延长合并窗口,不过他最终没有

    Angular 11.1.0 正式发布,支持 TypeScript 4.1

    。 近日,Angular 11.1.0 正式发布...