FlinkSQL使用DDL語句創建kafka源表

在Flink1.9.x版本中,社區版本的 Flink 新增 了一個 SQL DDL 的新特性，但是暫時還不支持流式的一些概念的定義,比如說水位(watermark). 下面主要介紹一下怎麼使用DDL創建kafak源表. 定義create table語句從kafka中讀取數據  """               |CREATE TABLE PERSON (               |    n

>>阅读原文<<