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)
相關文章
相關標籤/搜索