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

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

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

Sub-task

• [F -6321] - RocksDB state backend Checkpointing is not working with KeyedCEP.
• [F -7756] - RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

Bug

• [F -8423] - OperatorChain#pushToOperator catch block may fail with NPE
• [F -8451] - CaseClassSerializer is not backwards compatible in 1.4
• [F -8520] - CassandraConnectorITCase.testCassandraTableSink unstable on Travis
• [F -8621] - PrometheusReporterTest.endpointIsUnavailableAfterReporterIsClosed unstable on Travis
• [F -8692] - Mistake in MyMapFunction code snippet
• [F -8735] - Add savepoint migration ITCase that covers operator state
• [F -8741] - KafkaFetcher09/010/011 uses wrong user code classloader
• [F -8772] - F KafkaConsumer partitions discover missing a log parameter
• [F -8791] - Fix documentation on how to dependencies
• [F -8798] - Make commons-logging a parent-first pattern
• [F -8849] - Wrong from concepts/runtime to doc on chaining

改进

• [F -8202] - Update queryable section on configuration page
• [F -8574] - Add timestamps to travis logging messages
• [F -8576] - Log message for QueryableState loading failure too verbose
• [F -8652] - Reduce log level of QueryableStateClient.getKvState() to DEBUG

Task

• [F -8308] - Update yajl-ruby dependency to 1.3.1 or higher

更新

<dependency>
  <groupId>org.apache.f </groupId>
  <artifactId>f -java</artifactId>
  <version>1.4.2</version>
</dependency>
<dependency>
  <groupId>org.apache.f </groupId>
  <artifactId>f -streaming-java_2.11</artifactId>
  <version>1.4.2</version>
</dependency>
<dependency>
  <groupId>org.apache.f </groupId>
  <artifactId>f -clients_2.11</artifactId>
  <version>1.4.2</version>
</dependency>

二进制包下载地址：http://f .apache.org/downloads.html

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