Flink 1.11 Table & SQL深度解讀

1. kafka table DDL 動態table,后者定義覆蓋前者, 一次創建多次使用

 

2.clone table 完整繼承、或者覆蓋OPTION

 

3.性能測試體驗提升

 

 

 

4.kafka table options 提升

 

 

 

5.source & Sink重構

（1）ChangeLog：kafka sink 支持update delete  

（2） NoMatchingFactory 異常修復

（3）table schema 類型異常  

 

 

6.Hive 流批一體

 

 

 

 

 

 

 

 

 7.Hive Dialect

 

 

 

 8.Api Client

 

 

 

 

 

 

 以上內容整理自2020年6月14日阿里雲主辦的大數據+AI meetup