Apache Flink 1.4.0 发布了。ApacheFlink 是一个开源的流处理框架,应用于分布式,高性能,始终可用的,准确的数据流应用程序。
此版本更新内容:
Sub-task
- [FLINK-3551] – Sync Scala and Java Streaming Examples
- [FLINK-3582] – Add Iterator over State for All Keys in Partitioned State
- [FLINK-5270] – Refactor the batch Scala-expression Table API tests
- [FLINK-5272] – Refactor the stream Scala-expression Table API tests
- [FLINK-5509] – Replace QueryableStateClient keyHashCode argument
- [FLINK-5604] – Replace QueryableStateClient constructor
Bug
- [FLINK-3182] – TaskManagersHandler can block web frontend
- [FLINK-4047] – Fix documentation about determinism of KeySelectors
- [FLINK-4048] – Remove Hadoop dependencies from ExecutionEnvironment
- [FLINK-4228] – YARN artifact upload does not work with S3AFileSystem
- [FLINK-4500] – Cassandra sink can lose messages
- [FLINK-4660] – HadoopFileSystem (with S3A) may leak connections, which cause job to stuck in a restarting loop
- [FLINK-5070] – Unable to use Scala’s BeanProperty with classes
该版本可从以下网址下载: https://flink.apache.org/downloads.html
转自 http://www.oschina.net/news/91487/apache-flink-1-4-0-released