Apache Flink 1.4.1 发布了。ApacheFlink 是一个开源的流处理框架,应用于分布式,高性能,始终可用的,准确的数据流应用程序。
此版本更新内容:
Sub-task
RocksDB state backend Checkpointing is not working with KeyedCEP.
double buffer release in SpillableSubpartitionView
RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.
Restore failing from external checkpointing metadata.
Fix Mod scala function bug
Bug 修复
Java 8 - CommunityDetection.java:158 - java.lang.NullPointerException
Incompatible versions of httpcomponents jars for Flink kinesis connector
AsyncWaitOperator is not restarting when queue is full
IOManagerAsync not properly shut down in various tests
RocksDBAsyncSnapshotTest should use temp fold instead of fold with fixed name
Dangling reference generated after NFA clean up timed out SharedBufferEntry
软件详情:http://flink.apache.org/news/2018/02/15/release-1.4.1.html
下载地址:http://flink.apache.org/downloads.html
来自:开源中国社区