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

Apache Flink 1.4 系列的第二个 bug 修复版本已发布。此版本包含 10 多个修补程序和对 Flink 1.4.1 的小改进。官方强烈建议所有用户升级到 Flink 1.4.2。

下面的内容包含了所有修补程序的详细列表：

Sub-task

RocksDB state backend Checkpointing is not working with KeyedCEP.

RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

Bug

OperatorChain#pushToOperator catch block may fail with NPE

CaseClassSerializer is not backwards compatible in 1.4

CassandraConnectorITCase.testCassandraTableSink unstable on Travis

PrometheusReporterTest.endpointIsUnavailableAfterReporterIsClosed unstable on Travis

Mistake in MyMapFunction code snippet

Add savepoint migration ITCase that covers operator state

KafkaFetcher09/010/011 uses wrong user code classloader

FlinkKafkaConsumerBase partitions discover missing a log parameter

Fix documentation on how to link dependencies

Make commons-logging a parent-first pattern

Wrong link from concepts/runtime to doc on chaining

改进

Update queryable section on configuration page

Add timestamps to travis logging messages

Log message for QueryableState loading failure too verbose

Reduce log level of QueryableStateClient.getKvState() to DEBUG

Task

Update yajl-ruby dependency to 1.3.1 or higher

更新[code]
org.apache.flink
flink-java
1.4.2


org.apache.flink
flink-streaming-java_2.11
1.4.2


org.apache.flink
flink-clients_2.11
1.4.2
[/code]二进制包下载地址：http://flink.apache.org/downloads.html

Apache Flink 是高效和分布式的通用数据处理平台。Apache Flink 声明式的数据分析开源系统，结合了分布式 MapReduce 类平台的高效，灵活的编程和扩展性。同时在并行数据库发现查询优化方案。

来自:开源中国社区