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 项目的目标是开发一个流处理系统，以统一和支持多种形式的实时和离线数据处理应用程序以及事件驱动的应用程序。
