作者: baihuo
2018-03-09 09:07:02
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 类平台的高效，灵活的编程和扩展性。同时在并行数据库发现查询优化方案。
来自:开源中国社区