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

内容简介：Apache Flink 1.4.1 发布了。ApacheFlink 是一个开源的流处理框架，应用于分布式，高性能，始终可用的，准确的数据流应用程序。 此版本更新内容： Sub-task [FLINK-6321] - RocksDB state backend Checkpointing ...

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://www.oschina.net]

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持 码农网

查看所有标签

本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。