流处理框架:Apache Flink 1.9.3

Apache Flink 是高效和分布式的通用数据处理平台。

Apache Flink 声明式的数据分析开源系统,结合了分布式 MapReduce 类平台的高效,灵活的编程和扩展性。同时在并行数据库发现查询优化方案。

要求

  • Unix 类环境(Linux, Mac OS X, Cygwin)
  • git
  • Maven (at least version 3.0.4)
  • Java 6, 7 or 8 (Note that Oracle’s JDK 6 library will fail to build Flink, but is able to run a pre-compiled package without problem)
git clone https://github.com/apache/incubator-flink.git
cd incubator-flink
mvn clean package -DskipTests # this will take up to 5 minutes

Apache Flink 1.9 系列的第三个 bugfix 版本,总共包含 38 个修复程序以及针对 Flink 1.9.2 的改进。

部分更新内容:

  • [FLINK-14278] – 将 ioExecutor 传入 AbstractDispatcherResourceManagerComponentFactory
  • [FLINK-15908] – 在 1.9.x 文档中添加支持’pip install’的描述
  • [FLINK-15909] – 在后续 1.9.x 版本中加入 PyPI 的发布流程
  • [FLINK-15938] – 修复 StreamingJoinOperator 和 StreamingSemiAntiJoinOperator 中空闲状态没有被清理的问题
  • [FLINK-16018] – 改进提交批处理作业时的错误报告(代替 AskTimeoutException)
  • [FLINK-16031] – 改进 PyFlink 1.9.x README 文件中的描述
  • [FLINK-16167] – 升级关于 python shell 执行的文档
  • [FLINK-16280] – 修复关于 elasticsearch 连接器文档中的示例代码错误
  • [FLINK-16697] – 禁用 JMX 重新绑定功能
  • [FLINK-16862] – 移除 quickstarts 中的示例 url
  • [FLINK-16942] – ES 5 sink 支持用户选择 netty 传输客户端

详情查看 https://flink.apache.org/news/2020/04/24/release-1.9.3.html
下载地址 https://flink.apache.org/downloads.html#apache-flink-193

Apache Flink 项目的目标是开发一个流处理系统,以统一和支持多种形式的实时和离线数据处理应用程序以及事件驱动的应用程序。​​​​​​​

下载地址:

https://github.com/apache/flink/releases



                    

人已赞赏
博客

在线答题系统 WTS 0.9.2

2020-4-27 9:39:06

博客程序开发

简单易用的通用后台管理系统:web-flash 1.5

2020-4-29 11:26:54

0 条回复 A文章作者 M管理员
    暂无讨论,说说你的看法吧
个人中心
购物车
优惠劵
今日签到
有新私信 私信列表
搜索