内容简介:Apache Flink 1.8.0 已发布,该版本与之前的 1.x.y 版本 API 兼容。Apache Flink 是一个开源的流处理框架,应用于分布式、高性能、始终可用的、准确的数据流应用程序。 新特性和改进: Schema Evolution Story 最...
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
以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网
猜你喜欢:- Apache Flink 1.5.4 发布,开源流处理框架
- Apache Flink 1.5.4 发布,开源流处理框架
- Apache Flink 1.7.1 发布,开源流处理框架
- Apache Flink 1.6.3 发布,开源流处理框架
- Apache Flink 1.6.4 发布,开源流处理框架
- Apache Flink 1.9.0 发布,开源流处理框架
本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。