Apache Flink 1.8.0 发布，开源流处理框架

Apache Flink 1.8.0 已发布，该版本与之前的 1.x.y 版本 API 兼容。Apache Flink 是一个开源的流处理框架，应用于分布式、高性能、始终可用的、准确的数据流应用程序。

新特性和改进：

• Schema Evolution Story 最终版
• 基于 TTL 持续清除旧状态
• 使用用户定义的函数和聚合进行 SQL 模式检测
• 符合 RFC 的 CSV 格式
• 新的 KafkaDeserializationSchema，可以直接访问 ConsumerRecord
• FlinkKinesisConsumer 中的分片水印选项
• DynamoDB Streams 的新用户捕获表更改
• 支持用于子任务协调的全局聚合

重要变化：

• 使用 Flink 捆绑 Hadoop 库的更改：不再发布包含 hadoop 的便捷二进制文件
• FlinkKafkaConsumer 现在将根据主题规范过滤已恢复的分区
• 表 API 的 Maven 依赖更改：之前具有flink-table依赖关系的用户需要将依赖关系从flink-table-planner更新为正确的依赖关系 flink-table-api-*，具体取决于是使用 Java 还是 Scala： flink-table-api-java-bridge或者flink-table-api-scala-bridge

已知问题：

• 丢弃的检查点可能导致任务失败

详情请查阅发布公告。

下载地址：http://flink.apache.org/downloads.html

转自 https://www.oschina.net/news/105820/apache-flink-1-8-0-released