Apache Flink 1.6.0 继续围绕使用户能够无缝地运行快速数据处理并轻松构建数据驱动和数据密集型应用而改进,主要包括:
新增对 state TTL 的原生支持。此功能允许在 state 到期后进行清理;
继续完善 1.5.0 重构的 Flink 分布式架构,并简化容器设置;
进一步改进 SQL CLI,使得针对大量数据源执行流式处理和批处理查询更容易;
新增 StreamingFileSink ,以及对 ElasticSearch 6.x 的支持;
优化 Timer Deletions 。
完整更新内容请查阅发行说明:
https://flink.apache.org/news/2018/08/09/release-1.6.0.html
下载地址: