皇上,还记得我吗?我就是1999年那个Linux伊甸园啊-----24小时滚动更新开源资讯,全年无休!

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

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

c343231843d4e6657519d5736242a2e666b.jpg

新特性和改进:

  • 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

分享到:更多 ()