Apache Flink 1.8.1 已释出,这是 Apache Flink 1.8 系列的首个 bugfix 版本,此版本也与之前的 1.x.y 版本 API 相容。
1.8.1 包含了超过 40 个修复程式和小的改进,官方建议所有使用者都升级到最新版本。
Maven
org.apache.flink
flink-java
1.8.1
org.apache.flink
flink-streaming-java_2.11
1.8.1
org.apache.flink
flink-clients_2.11
1.8.1
下载地址:http://flink.apache.org/downloads.html
列举几个改进如下:
[FLINK-11126] - 在 TaskManager 凭据中对 AMRMToken 进行过滤[FLINK-12137] - 在 flink 的流联结器上新增更多适当的说明[FLINK-12169] - 改进 MessageAcknowledgingSourceBase 的 Javadoc[FLINK-12378] - 整合档案系统文件[FLINK-12391] - 为 transfer.sh 新增超时功能[FLINK-12539] - StreamingFileSink:使类可扩充套件以针对不同的用例进行自定义Apache Flink 是一个开源的流处理框架,应用于分散式、高效能、始终可用的、准确的资料流应用程序。






























