Apache Flink 1.4.1 发布，通用数据处理平台

Linuxeden 开源社区 --

Apache Flink 1.4.1 发布了。ApacheFlink 是一个开源的流处理框架，应用于分布式，高性能，始终可用的，准确的数据流应用程序。

此版本更新内容：

Sub-task

• [FLINK-6321] – RocksDB state backend Checkpointing is not working with KeyedCEP.
• [FLINK-7499] – double buffer release in SpillableSubpartitionView
• [FLINK-7756] – RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.
• [FLINK-7760] – Restore failing from external checkpointing metadata.
• [FLINK-8323] – Fix Mod scala function bug

Bug 修复

• [FLINK-5506] – Java 8 – CommunityDetection.java:158 – java.lang.NullPointerException
• [FLINK-6951] – Incompatible versions of httpcomponents jars for Flink kinesis connector
• [FLINK-7949] – AsyncWaitOperator is not restarting when queue is full
• [FLINK-8145] – IOManagerAsync not properly shut down in various tests
• [FLINK-8200] – RocksDBAsyncSnapshotTest should use temp fold instead of fold with fixed name
• [FLINK-8226] – Dangling reference generated after NFA clean up timed out SharedBufferEntry

完整内容请查看 发布主页 。

下载地址：http://flink.apache.org/downloads.html

转自 http://ift.tt/2C3LS48

The post Apache Flink 1.4.1 发布，通用数据处理平台 appeared first on Linuxeden开源社区.

http://ift.tt/2sz001r