1. kafka table DDL 动态table,后者定义覆盖前者, 一次创建多次使用

Flink 1.11 Table & SQL深度解读

2.clone table 完整继承、或者覆盖OPTION

Flink 1.11 Table & SQL深度解读

3.性能测试体验提升

Flink 1.11 Table & SQL深度解读

4.kafka table options 提升

Flink 1.11 Table & SQL深度解读

5.source & Sink重构

(1)ChangeLog:kafka sink 支持update delete
(2) NoMatchingFactory 异常修复
(3)table schema 类型异常

Flink 1.11 Table & SQL深度解读

6.Hive 流批一体

Flink 1.11 Table & SQL深度解读
Flink 1.11 Table & SQL深度解读
Flink 1.11 Table & SQL深度解读

Flink 1.11 Table & SQL深度解读
Flink 1.11 Table & SQL深度解读

7.Hive Dialect

Flink 1.11 Table & SQL深度解读

Flink 1.11 Table & SQL深度解读

8.Api Client

Flink 1.11 Table & SQL深度解读
Flink 1.11 Table & SQL深度解读

Flink 1.11 Table & SQL深度解读

以上内容整理自2020年6月14日阿里云主办的大数据+AI meetup

相关文章: